Batch Sensor Async¶
To wait asynchronously for AWS Batch job to complete
BatchSensorAsync
.
batch_job_sensor = BatchSensorAsync(
task_id="sense_job",
job_id="{{ task_instance.xcom_pull(task_ids='list_jobs', dag_id='example_async_batch', key='return_value') }}",
aws_conn_id=AWS_CONN_ID,
region_name=AWS_DEFAULT_REGION,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/amazon/aws/example_dags/example_batch.py