airflow.providers.amazon.aws.sensors.glue

Module Contents

class airflow.providers.amazon.aws.sensors.glue.AwsGlueJobSensor(*, job_name: str, run_id: str, aws_conn_id: str = 'aws_default', **kwargs)[source]

Bases: airflow.sensors.base.BaseSensorOperator

Waits for an AWS Glue Job to reach any of the status below 'FAILED', 'STOPPED', 'SUCCEEDED'

Parameters

  • job_name (str) -- The AWS Glue Job unique name

  • run_id (str) -- The AWS Glue current running job identifier

template_fields = ['job_name', 'run_id'][source]
poke(self, context)[source]

Was this entry helpful?