The scheduler does not appear to be running. Last heartbeat was received .
The DAGs list may not update, and new tasks will not be scheduled.
State | Dag Id | Task Id | Execution Date | Operator | Start Date | End Date | Duration | Job Id | Hostname | Unixname | Priority Weight | Queue | Queued Dttm | Try Number | Pool | Log Url | ||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
success | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:12:01.997920 | 394969 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:00.845124 | 394968 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:00.899987 | 394966 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:03.035884 | 101899 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.775136 | 101897 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:03.178126 | 101895 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.717766 | 4698 |
|
airflow | 1 | default |
|
4 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.677410 | 4697 |
|
airflow | 2 | default |
|
4 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.524769 | 4696 |
|
airflow | 3 | default |
|
4 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.652978 | 4548 |
|
airflow | 2 | default |
|
3 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.508401 | 4547 |
|
airflow | 3 | default |
|
3 | default_pool | |||
success | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:04:01.927878 | 4536 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.683406 | 4535 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.570057 | 4534 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.619081 | 4531 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.669744 | 4530 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.514866 | 4529 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.708439 | 4527 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.714357 | 4526 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.518031 | 4525 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.781374 | 4443 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.671732 | 4442 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.496109 | 4441 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.679574 | 4429 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.679288 | 4428 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.658327 | 4427 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.495560 | 4426 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.762214 | 4425 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.561996 | 4424 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:03.013091 | 4421 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.689752 | 4420 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.578249 | 4419 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.721088 | 4416 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.610870 | 4415 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.665954 | 4413 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.495116 | 4412 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.651322 | 4409 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.496672 | 4408 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.631753 | 4406 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.521479 | 4405 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.685595 | 4402 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.525719 | 4401 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.661398 | 4399 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.538718 | 4398 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.679937 | 4396 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.647750 | 4395 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.676688 | 4392 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.631768 | 4391 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.690809 | 4388 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.821222 | 4387 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.513817 | 4362 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.497270 | 4361 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.618356 | 4359 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.635399 | 4358 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.547031 | 4355 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.575994 | 4354 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.602977 | 4347 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.501705 | 4346 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.556259 | 4344 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.498527 | 4343 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.693905 | 4340 |
|
airflow | 3 | default |
|
2 | default_pool |