Task Instances

Reset Filters
  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-flow-job_v002 create_emr_steps 2021-05-10T13:00:00+00:00 PythonOperator 2021-05-10T14:00:05.414549+00:00 2021-05-10T14:00:08.530968+00:00 0:00:03.116419 26565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T14:00:03.147749+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T12:00:00+00:00 TriggerDagRunOperator 2021-05-10T13:10:10.818401+00:00 2021-05-10T13:10:11.347001+00:00 0:00:00.528600 26557 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T13:10:08.306957+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T12:00:00+00:00 TriggerDagRunOperator 2021-05-10T13:10:10.527850+00:00 2021-05-10T13:10:10.947744+00:00 0:00:00.419894 26556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T13:10:08.306919+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T12:00:00+00:00 EmrJobFlowSensor 2021-05-10T13:00:57.008716+00:00 2021-05-10T13:09:59.736294+00:00 0:09:02.727578 26552 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T13:00:54.894534+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T13:00:37.103890+00:00 2021-05-10T13:00:38.813097+00:00 0:00:01.709207 26551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T13:00:34.855200+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T12:00:00+00:00 PythonOperator 2021-05-10T13:00:15.161403+00:00 2021-05-10T13:00:18.279169+00:00 0:00:03.117766 26550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T13:00:12.724919+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T11:00:00+00:00 TriggerDagRunOperator 2021-05-10T12:10:04.034245+00:00 2021-05-10T12:10:04.574891+00:00 0:00:00.540646 26542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T12:10:01.466341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T11:00:00+00:00 TriggerDagRunOperator 2021-05-10T12:10:03.975488+00:00 2021-05-10T12:10:04.390855+00:00 0:00:00.415367 26541 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T12:10:01.466389+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T11:00:00+00:00 EmrJobFlowSensor 2021-05-10T12:00:56.104505+00:00 2021-05-10T12:09:58.989406+00:00 0:09:02.884901 26537 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T12:00:53.950865+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T12:00:36.231147+00:00 2021-05-10T12:00:37.903671+00:00 0:00:01.672524 26536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T12:00:33.907599+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T11:00:00+00:00 PythonOperator 2021-05-10T12:00:12.039634+00:00 2021-05-10T12:00:15.168909+00:00 0:00:03.129275 26535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T12:00:09.797478+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T10:00:00+00:00 TriggerDagRunOperator 2021-05-10T11:11:09.509808+00:00 2021-05-10T11:11:10.037142+00:00 0:00:00.527334 26527 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T11:11:06.890680+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T10:00:00+00:00 TriggerDagRunOperator 2021-05-10T11:11:09.332099+00:00 2021-05-10T11:11:09.742719+00:00 0:00:00.410620 26526 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T11:11:06.890712+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T10:00:00+00:00 EmrJobFlowSensor 2021-05-10T11:00:55.632520+00:00 2021-05-10T11:10:58.638346+00:00 0:10:03.005826 26522 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T11:00:53.292036+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T11:00:33.338503+00:00 2021-05-10T11:00:35.037926+00:00 0:00:01.699423 26521 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T11:00:31.189094+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T10:00:00+00:00 PythonOperator 2021-05-10T11:00:13.782181+00:00 2021-05-10T11:00:17.036837+00:00 0:00:03.254656 26520 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T11:00:11.152861+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T09:00:00+00:00 TriggerDagRunOperator 2021-05-10T10:08:56.914156+00:00 2021-05-10T10:08:57.432484+00:00 0:00:00.518328 26512 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T10:08:53.758513+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T09:00:00+00:00 TriggerDagRunOperator 2021-05-10T10:08:56.704663+00:00 2021-05-10T10:08:57.284425+00:00 0:00:00.579762 26511 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T10:08:53.758442+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T09:00:00+00:00 EmrJobFlowSensor 2021-05-10T10:00:47.214135+00:00 2021-05-10T10:08:49.827310+00:00 0:08:02.613175 26507 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T10:00:44.706488+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T10:00:25.171040+00:00 2021-05-10T10:00:26.987442+00:00 0:00:01.816402 26506 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T10:00:22.748539+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T09:00:00+00:00 PythonOperator 2021-05-10T10:00:04.885383+00:00 2021-05-10T10:00:08.004536+00:00 0:00:03.119153 26505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T10:00:02.644106+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T08:00:00+00:00 TriggerDagRunOperator 2021-05-10T09:21:11.757205+00:00 2021-05-10T09:21:12.278289+00:00 0:00:00.521084 26497 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T09:21:09.393121+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T08:00:00+00:00 TriggerDagRunOperator 2021-05-10T09:21:11.529016+00:00 2021-05-10T09:21:11.945078+00:00 0:00:00.416062 26496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T09:21:09.393089+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T08:00:00+00:00 EmrJobFlowSensor 2021-05-10T09:00:49.130983+00:00 2021-05-10T09:20:53.558381+00:00 0:20:04.427398 26492 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T09:00:46.719382+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T09:00:27.244680+00:00 2021-05-10T09:00:29.042175+00:00 0:00:01.797495 26491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T09:00:24.775028+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T08:00:00+00:00 PythonOperator 2021-05-10T09:00:07.157671+00:00 2021-05-10T09:00:10.301598+00:00 0:00:03.143927 26490 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T09:00:04.686177+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T07:00:00+00:00 TriggerDagRunOperator 2021-05-10T08:10:15.864545+00:00 2021-05-10T08:10:16.398394+00:00 0:00:00.533849 26482 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T08:10:13.502801+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T07:00:00+00:00 TriggerDagRunOperator 2021-05-10T08:10:15.764878+00:00 2021-05-10T08:10:16.151307+00:00 0:00:00.386429 26481 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T08:10:13.502833+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T07:00:00+00:00 EmrJobFlowSensor 2021-05-10T08:00:50.465765+00:00 2021-05-10T08:09:53.410567+00:00 0:09:02.944802 26477 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T08:00:48.109486+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T08:00:28.211282+00:00 2021-05-10T08:00:29.938140+00:00 0:00:01.726858 26476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T08:00:26.040206+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T07:00:00+00:00 PythonOperator 2021-05-10T08:00:08.198944+00:00 2021-05-10T08:00:11.305429+00:00 0:00:03.106485 26475 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T08:00:05.924567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T06:00:00+00:00 TriggerDagRunOperator 2021-05-10T07:10:10.702845+00:00 2021-05-10T07:10:11.244664+00:00 0:00:00.541819 26467 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T07:10:08.060686+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T06:00:00+00:00 TriggerDagRunOperator 2021-05-10T07:10:10.371774+00:00 2021-05-10T07:10:10.765383+00:00 0:00:00.393609 26466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T07:10:08.060645+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T06:00:00+00:00 EmrJobFlowSensor 2021-05-10T07:00:46.765249+00:00 2021-05-10T07:09:49.514922+00:00 0:09:02.749673 26462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T07:00:44.601235+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T07:00:24.743587+00:00 2021-05-10T07:00:26.486535+00:00 0:00:01.742948 26461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T07:00:22.506202+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T06:00:00+00:00 PythonOperator 2021-05-10T07:00:04.784355+00:00 2021-05-10T07:00:07.867073+00:00 0:00:03.082718 26460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T07:00:02.488908+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T05:00:00+00:00 TriggerDagRunOperator 2021-05-10T06:11:01.224149+00:00 2021-05-10T06:11:01.639287+00:00 0:00:00.415138 26452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T06:10:58.280773+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T05:00:00+00:00 TriggerDagRunOperator 2021-05-10T06:11:00.847457+00:00 2021-05-10T06:11:01.399097+00:00 0:00:00.551640 26451 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T06:10:58.280817+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T05:00:00+00:00 EmrJobFlowSensor 2021-05-10T06:00:49.355365+00:00 2021-05-10T06:10:52.302680+00:00 0:10:02.947315 26447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T06:00:47.157404+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T06:00:27.409499+00:00 2021-05-10T06:00:29.165537+00:00 0:00:01.756038 26446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T06:00:25.155878+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T05:00:00+00:00 PythonOperator 2021-05-10T06:00:05.822028+00:00 2021-05-10T06:00:08.950425+00:00 0:00:03.128397 26445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T06:00:03.078093+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T04:00:00+00:00 TriggerDagRunOperator 2021-05-10T05:10:25.351178+00:00 2021-05-10T05:10:25.867785+00:00 0:00:00.516607 26437 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T05:10:23.009614+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T04:00:00+00:00 TriggerDagRunOperator 2021-05-10T05:10:25.292880+00:00 2021-05-10T05:10:25.697479+00:00 0:00:00.404599 26436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T05:10:23.009645+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T04:00:00+00:00 EmrJobFlowSensor 2021-05-10T05:01:00.119424+00:00 2021-05-10T05:10:03.110664+00:00 0:09:02.991240 26432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T05:00:57.688511+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T05:00:37.836329+00:00 2021-05-10T05:00:39.582607+00:00 0:00:01.746278 26431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T05:00:35.658790+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T04:00:00+00:00 PythonOperator 2021-05-10T05:00:16.251784+00:00 2021-05-10T05:00:19.356960+00:00 0:00:03.105176 26430 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T05:00:13.599893+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T03:00:00+00:00 TriggerDagRunOperator 2021-05-10T04:11:08.406021+00:00 2021-05-10T04:11:08.969588+00:00 0:00:00.563567 26422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T04:11:05.822062+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T03:00:00+00:00 TriggerDagRunOperator 2021-05-10T04:11:07.984026+00:00 2021-05-10T04:11:08.414394+00:00 0:00:00.430368 26421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T04:11:05.822033+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T03:00:00+00:00 EmrJobFlowSensor 2021-05-10T04:00:46.928584+00:00 2021-05-10T04:10:49.844302+00:00 0:10:02.915718 26417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T04:00:44.655177+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T04:00:24.646990+00:00 2021-05-10T04:00:26.398621+00:00 0:00:01.751631 26416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T04:00:22.504248+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T03:00:00+00:00 PythonOperator 2021-05-10T04:00:04.927118+00:00 2021-05-10T04:00:08.096253+00:00 0:00:03.169135 26415 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T04:00:02.485324+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T02:00:00+00:00 TriggerDagRunOperator 2021-05-10T03:10:17.393813+00:00 2021-05-10T03:10:17.931915+00:00 0:00:00.538102 26407 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T03:10:15.124933+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T02:00:00+00:00 TriggerDagRunOperator 2021-05-10T03:10:17.178611+00:00 2021-05-10T03:10:17.635028+00:00 0:00:00.456417 26406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T03:10:15.124999+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T02:00:00+00:00 EmrJobFlowSensor 2021-05-10T03:00:50.342218+00:00 2021-05-10T03:09:53.117066+00:00 0:09:02.774848 26402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T03:00:48.037723+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T03:00:28.108485+00:00 2021-05-10T03:00:29.837631+00:00 0:00:01.729146 26401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T03:00:26.021145+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T02:00:00+00:00 PythonOperator 2021-05-10T03:00:08.609987+00:00 2021-05-10T03:00:11.713471+00:00 0:00:03.103484 26400 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T03:00:06.003618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T01:00:00+00:00 TriggerDagRunOperator 2021-05-10T02:11:20.123028+00:00 2021-05-10T02:11:20.708489+00:00 0:00:00.585461 26392 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T02:11:17.749947+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T01:00:00+00:00 TriggerDagRunOperator 2021-05-10T02:11:19.933560+00:00 2021-05-10T02:11:20.362223+00:00 0:00:00.428663 26391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T02:11:17.749917+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T01:00:00+00:00 EmrJobFlowSensor 2021-05-10T02:00:58.850604+00:00 2021-05-10T02:11:01.685978+00:00 0:10:02.835374 26387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T02:00:56.555660+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T02:00:38.925277+00:00 2021-05-10T02:00:40.749959+00:00 0:00:01.824682 26386 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T02:00:36.543740+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T01:00:00+00:00 PythonOperator 2021-05-10T02:00:10.976586+00:00 2021-05-10T02:00:14.216244+00:00 0:00:03.239658 26385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T02:00:08.515786+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T00:00:00+00:00 TriggerDagRunOperator 2021-05-10T01:10:20.990143+00:00 2021-05-10T01:10:21.542498+00:00 0:00:00.552355 26377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T01:10:18.408589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T00:00:00+00:00 TriggerDagRunOperator 2021-05-10T01:10:20.570236+00:00 2021-05-10T01:10:20.952968+00:00 0:00:00.382732 26376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T01:10:18.408620+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T00:00:00+00:00 EmrJobFlowSensor 2021-05-10T01:01:09.927305+00:00 2021-05-10T01:10:12.847360+00:00 0:09:02.920055 26372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T01:01:07.461360+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T01:00:43.646287+00:00 2021-05-10T01:00:45.538793+00:00 0:00:01.892506 26371 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T01:00:41.381290+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T00:00:00+00:00 PythonOperator 2021-05-10T01:00:19.702686+00:00 2021-05-10T01:00:22.797173+00:00 0:00:03.094487 26370 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T01:00:17.362838+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T23:00:00+00:00 TriggerDagRunOperator 2021-05-10T00:10:31.021342+00:00 2021-05-10T00:10:31.550564+00:00 0:00:00.529222 26362 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T00:10:28.553361+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T23:00:00+00:00 TriggerDagRunOperator 2021-05-10T00:10:30.874713+00:00 2021-05-10T00:10:31.301561+00:00 0:00:00.426848 26361 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T00:10:28.553407+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T23:00:00+00:00 EmrJobFlowSensor 2021-05-10T00:01:07.931157+00:00 2021-05-10T00:10:10.796315+00:00 0:09:02.865158 26357 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T00:01:05.689348+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T00:00:43.911916+00:00 2021-05-10T00:00:45.644069+00:00 0:00:01.732153 26356 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T00:00:41.617348+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T23:00:00+00:00 PythonOperator 2021-05-10T00:00:11.814823+00:00 2021-05-10T00:00:14.927705+00:00 0:00:03.112882 26355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T00:00:09.603642+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T22:00:00+00:00 TriggerDagRunOperator 2021-05-09T23:10:20.877051+00:00 2021-05-09T23:10:21.401410+00:00 0:00:00.524359 26347 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T23:10:18.493692+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T22:00:00+00:00 TriggerDagRunOperator 2021-05-09T23:10:20.553421+00:00 2021-05-09T23:10:20.958767+00:00 0:00:00.405346 26346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T23:10:18.493719+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T22:00:00+00:00 EmrJobFlowSensor 2021-05-09T23:01:05.888050+00:00 2021-05-09T23:10:08.613923+00:00 0:09:02.725873 26341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T23:01:03.690898+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T23:00:43.943793+00:00 2021-05-09T23:00:45.812265+00:00 0:00:01.868472 26339 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T23:00:41.617720+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T22:00:00+00:00 PythonOperator 2021-05-09T23:00:17.885427+00:00 2021-05-09T23:00:21.640312+00:00 0:00:03.754885 26337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T23:00:15.595877+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T21:00:00+00:00 TriggerDagRunOperator 2021-05-09T22:10:24.838309+00:00 2021-05-09T22:10:25.268151+00:00 0:00:00.429842 26329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T22:10:22.482575+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T21:00:00+00:00 TriggerDagRunOperator 2021-05-09T22:10:24.828893+00:00 2021-05-09T22:10:25.392057+00:00 0:00:00.563164 26328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T22:10:22.482507+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T21:00:00+00:00 EmrJobFlowSensor 2021-05-09T22:01:03.963516+00:00 2021-05-09T22:10:06.798094+00:00 0:09:02.834578 26324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T22:01:01.610107+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T22:00:37.990246+00:00 2021-05-09T22:00:39.697643+00:00 0:00:01.707397 26323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T22:00:35.646351+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T21:00:00+00:00 PythonOperator 2021-05-09T22:00:17.902699+00:00 2021-05-09T22:00:21.009521+00:00 0:00:03.106822 26322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T22:00:15.544251+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T20:00:00+00:00 TriggerDagRunOperator 2021-05-09T21:09:23.002735+00:00 2021-05-09T21:09:23.434126+00:00 0:00:00.431391 26314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T21:09:20.352669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T20:00:00+00:00 TriggerDagRunOperator 2021-05-09T21:09:22.871848+00:00 2021-05-09T21:09:23.410780+00:00 0:00:00.538932 26313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T21:09:20.352721+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T20:00:00+00:00 EmrJobFlowSensor 2021-05-09T21:01:11.732196+00:00 2021-05-09T21:09:14.376657+00:00 0:08:02.644461 26309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T21:01:09.517453+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T21:00:45.815430+00:00 2021-05-09T21:00:47.687236+00:00 0:00:01.871806 26308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T21:00:43.495213+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T20:00:00+00:00 PythonOperator 2021-05-09T21:00:23.733134+00:00 2021-05-09T21:00:26.954689+00:00 0:00:03.221555 26307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T21:00:21.454192+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T19:00:00+00:00 TriggerDagRunOperator 2021-05-09T20:10:21.911031+00:00 2021-05-09T20:10:22.459098+00:00 0:00:00.548067 26299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T20:10:19.630366+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T19:00:00+00:00 TriggerDagRunOperator 2021-05-09T20:10:21.801295+00:00 2021-05-09T20:10:22.266418+00:00 0:00:00.465123 26298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T20:10:19.630397+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T19:00:00+00:00 EmrJobFlowSensor 2021-05-09T20:01:04.719597+00:00 2021-05-09T20:10:07.462787+00:00 0:09:02.743190 26294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T20:01:02.507963+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T20:00:42.809202+00:00 2021-05-09T20:00:44.626642+00:00 0:00:01.817440 26293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T20:00:40.490357+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T19:00:00+00:00 PythonOperator 2021-05-09T20:00:22.538372+00:00 2021-05-09T20:00:25.665845+00:00 0:00:03.127473 26292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T20:00:20.433462+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T18:00:00+00:00 TriggerDagRunOperator 2021-05-09T19:11:16.808752+00:00 2021-05-09T19:11:17.355128+00:00 0:00:00.546376 26284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T19:11:14.551432+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T18:00:00+00:00 TriggerDagRunOperator 2021-05-09T19:11:16.734750+00:00 2021-05-09T19:11:17.142794+00:00 0:00:00.408044 26283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T19:11:14.551465+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T18:00:00+00:00 EmrJobFlowSensor 2021-05-09T19:01:04.114877+00:00 2021-05-09T19:11:06.994541+00:00 0:10:02.879664 26279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T19:01:01.675557+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T19:00:41.793319+00:00 2021-05-09T19:00:43.637066+00:00 0:00:01.843747 26278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T19:00:39.598568+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T18:00:00+00:00 PythonOperator 2021-05-09T19:00:20.016605+00:00 2021-05-09T19:00:23.138072+00:00 0:00:03.121467 26277 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T19:00:17.574560+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T17:00:00+00:00 TriggerDagRunOperator 2021-05-09T18:11:43.380252+00:00 2021-05-09T18:11:43.797216+00:00 0:00:00.416964 26270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T18:11:40.563546+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T17:00:00+00:00 TriggerDagRunOperator 2021-05-09T18:11:43.400923+00:00 2021-05-09T18:11:43.949390+00:00 0:00:00.548467 26269 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T18:11:40.563578+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T17:00:00+00:00 EmrJobFlowSensor 2021-05-09T18:00:50.812854+00:00 2021-05-09T18:10:53.706903+00:00 0:10:02.894049 26264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T18:00:48.630998+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T18:00:29.040003+00:00 2021-05-09T18:00:30.871923+00:00 0:00:01.831920 26263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T18:00:26.612496+00:00 2 default_pool