`airflow.providers.apache.flink.sensors.flink_kubernetes`¶

Module Contents¶

Classes¶

FlinkKubernetesSensor

Checks flinkDeployment object in kubernetes cluster.

class airflow.providers.apache.flink.sensors.flink_kubernetes.FlinkKubernetesSensor(*, application_name, attach_log=False, namespace=None, kubernetes_conn_id='kubernetes_default', api_group='flink.apache.org', api_version='v1beta1', plural='flinkdeployments', **kwargs)[source]¶

Bases: airflow.sensors.base.BaseSensorOperator

Checks flinkDeployment object in kubernetes cluster.

See also

For more detail about Flink Deployment Object have a look at the reference: https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-main/docs/custom-resource/reference/#flinkdeployment

Parameters

application_name (str) – flink Application resource name
namespace (str | None) – the kubernetes namespace where the flinkDeployment reside in
kubernetes_conn_id (str) – The kubernetes connection to Kubernetes cluster
attach_log (bool) – determines whether logs for driver pod should be appended to the sensor log
api_group (str) – kubernetes api group of flinkDeployment
api_version (str) – kubernetes api version of flinkDeployment
plural (str) – kubernetes api custom object plural

template_fields: Sequence[str] = ('application_name', 'namespace')[source]¶

FAILURE_STATES = ('MISSING', 'ERROR')[source]¶

SUCCESS_STATES = ('READY',)[source]¶

poke(context)[source]¶

Override when deriving this class.

airflow.providers.apache.flink.sensors.flink_kubernetes¶

Module Contents¶

Classes¶

`airflow.providers.apache.flink.sensors.flink_kubernetes`¶