airflow.providers.alibaba.cloud.sensors.analyticdb_spark¶

Classes¶

AnalyticDBSparkSensor

Monitor a AnalyticDB Spark session for termination.

Module Contents¶

class airflow.providers.alibaba.cloud.sensors.analyticdb_spark.AnalyticDBSparkSensor(*, app_id, adb_spark_conn_id='adb_spark_default', region=None, **kwargs)[source]¶

Bases: airflow.sensors.base.BaseSensorOperator

Monitor a AnalyticDB Spark session for termination.

Parameters:

app_id (str) – identifier of the monitored app depends on the option that’s being modified.
adb_spark_conn_id (str) – reference to a pre-defined ADB Spark connection.
region (str | None) – AnalyticDB MySQL region you want to submit spark application.

template_fields: collections.abc.Sequence[str] = ('app_id',)[source]¶

app_id[source]¶

property hook: airflow.providers.alibaba.cloud.hooks.analyticdb_spark.AnalyticDBSparkHook[source]¶

Get valid hook.

poke(context)[source]¶

Override when deriving this class.