astronomer.providers.databricks.triggers.databricks

Classes

DatabricksTrigger

This class is deprecated and will be removed in 2.0.0.

Module Contents

class astronomer.providers.databricks.triggers.databricks.DatabricksTrigger(conn_id, task_id, run_id, retry_limit, retry_delay, polling_period_seconds, job_id=None, run_page_url=None)

Bases: airflow.triggers.base.BaseTrigger

This class is deprecated and will be removed in 2.0.0. Use :class: ~airflow.providers.databricks.triggers.databricks.DatabricksExecutionTrigger instead.

conn_id

task_id

run_id

job_id

run_page_url

retry_limit

retry_delay

polling_period_seconds

serialize()

Serializes DatabricksTrigger arguments and classpath.

async run()

Makes a series of asynchronous http calls via a Databrick hook. It yields a Trigger if response is a 200 and run_state is successful, will retry the call up to the retry limit if the error is ‘retryable’, otherwise it throws an exception.