airflow.providers.amazon.aws.sensors.batch

Module Contents

Classes

BatchSensor

Asks for the state of the Batch Job execution until it reaches a failure state or success state.
class airflow.providers.amazon.aws.sensors.batch.BatchSensor(*, job_id: str, aws_conn_id: str = 'aws_default', region_name: Optional[str] = None, **kwargs)[source]

Bases: airflow.sensors.base.BaseSensorOperator

Asks for the state of the Batch Job execution until it reaches a failure state or success state. If the job fails, the task will fail.

Parameters

  • job_id (str) -- Batch job_id to check the state for

  • aws_conn_id (str) -- aws connection to use, defaults to 'aws_default'

template_fields :Sequence[str] = ['job_id'][source]
template_ext :Sequence[str] = [][source]
ui_color = #66c3ff[source]
poke(self, context: airflow.utils.context.Context) → bool[source]

Function that the sensors defined while deriving this class should override.

get_hook(self) → airflow.providers.amazon.aws.hooks.batch_client.AwsBatchClientHook[source]

Create and return a AwsBatchClientHook

Was this entry helpful?