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 trigger_dagrun_campaign-history-job_v002 2023-03-24T19:00:00+00:00 TriggerDagRunOperator 2023-03-24T20:11:25.105846+00:00 2023-03-24T20:11:25.734282+00:00 0:00:00.628436 358639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T20:11:22.397024+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T19:00:00+00:00 EmrJobFlowSensor 2023-03-24T20:00:57.863142+00:00 2023-03-24T20:10:59.653757+00:00 0:10:01.790615 358633 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T20:00:55.305816+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T20:00:35.750923+00:00 2023-03-24T20:00:36.586312+00:00 0:00:00.835389 358631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T20:00:33.198154+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T19:00:00+00:00 PythonOperator 2023-03-24T20:00:15.718205+00:00 2023-03-24T20:00:18.957146+00:00 0:00:03.238941 358629 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T20:00:13.192374+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T18:00:00+00:00 TriggerDagRunOperator 2023-03-24T19:11:24.951048+00:00 2023-03-24T19:11:25.449408+00:00 0:00:00.498360 358619 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T19:11:22.330714+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T18:00:00+00:00 TriggerDagRunOperator 2023-03-24T19:11:24.803802+00:00 2023-03-24T19:11:25.267183+00:00 0:00:00.463381 358618 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T19:11:22.330685+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T18:00:00+00:00 EmrJobFlowSensor 2023-03-24T19:00:57.491647+00:00 2023-03-24T19:10:59.274901+00:00 0:10:01.783254 358611 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T19:00:55.122726+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T19:00:38.497500+00:00 2023-03-24T19:00:39.318785+00:00 0:00:00.821285 358609 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T19:00:34.977112+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T18:00:00+00:00 PythonOperator 2023-03-24T19:00:13.565303+00:00 2023-03-24T19:00:16.771642+00:00 0:00:03.206339 358607 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T19:00:11.008287+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T17:00:00+00:00 TriggerDagRunOperator 2023-03-24T18:12:44.093697+00:00 2023-03-24T18:12:44.573146+00:00 0:00:00.479449 358598 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T18:12:41.406315+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T17:00:00+00:00 TriggerDagRunOperator 2023-03-24T18:12:43.956258+00:00 2023-03-24T18:12:44.422795+00:00 0:00:00.466537 358597 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T18:12:41.406355+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T17:00:00+00:00 EmrJobFlowSensor 2023-03-24T18:01:31.974356+00:00 2023-03-24T18:12:33.722080+00:00 0:11:01.747724 358590 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T18:01:29.769967+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T18:01:11.932083+00:00 2023-03-24T18:01:12.803791+00:00 0:00:00.871708 358588 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T18:01:09.749462+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T17:00:00+00:00 PythonOperator 2023-03-24T18:00:51.338843+00:00 2023-03-24T18:00:57.032139+00:00 0:00:05.693296 358586 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T18:00:47.732570+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T16:00:00+00:00 TriggerDagRunOperator 2023-03-24T17:13:30.307837+00:00 2023-03-24T17:13:30.869581+00:00 0:00:00.561744 358576 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T17:13:27.589315+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T16:00:00+00:00 TriggerDagRunOperator 2023-03-24T17:13:29.991552+00:00 2023-03-24T17:13:30.576292+00:00 0:00:00.584740 358575 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T17:13:27.589287+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T16:00:00+00:00 EmrJobFlowSensor 2023-03-24T17:01:00.717124+00:00 2023-03-24T17:11:02.616573+00:00 0:10:01.899449 358567 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T17:00:58.482751+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T17:00:38.801507+00:00 2023-03-24T17:00:39.620310+00:00 0:00:00.818803 358565 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T17:00:36.463670+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T16:00:00+00:00 PythonOperator 2023-03-24T17:00:18.838916+00:00 2023-03-24T17:00:22.910019+00:00 0:00:04.071103 358563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T17:00:16.447976+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T15:00:00+00:00 TriggerDagRunOperator 2023-03-24T16:15:39.644733+00:00 2023-03-24T16:15:40.122627+00:00 0:00:00.477894 358556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T16:15:37.242225+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T15:00:00+00:00 TriggerDagRunOperator 2023-03-24T16:15:39.576188+00:00 2023-03-24T16:15:40.059003+00:00 0:00:00.482815 358555 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T16:15:37.242254+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T15:00:00+00:00 EmrJobFlowSensor 2023-03-24T16:03:11.997563+00:00 2023-03-24T16:13:13.798421+00:00 0:10:01.800858 358549 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T16:03:09.139733+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T16:02:49.661747+00:00 2023-03-24T16:02:50.566451+00:00 0:00:00.904704 358547 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T16:02:47.119162+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T15:00:00+00:00 PythonOperator 2023-03-24T16:02:27.338848+00:00 2023-03-24T16:02:31.402683+00:00 0:00:04.063835 358545 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T16:02:25.107232+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T14:00:00+00:00 TriggerDagRunOperator 2023-03-24T15:19:52.095619+00:00 2023-03-24T15:19:52.539880+00:00 0:00:00.444261 358538 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T15:19:49.124708+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T14:00:00+00:00 TriggerDagRunOperator 2023-03-24T15:19:51.806479+00:00 2023-03-24T15:19:52.318463+00:00 0:00:00.511984 358537 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T15:19:49.124664+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T14:00:00+00:00 EmrJobFlowSensor 2023-03-24T15:09:39.458919+00:00 2023-03-24T15:19:41.772855+00:00 0:10:02.313936 358532 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T15:09:36.820529+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T15:09:16.977388+00:00 2023-03-24T15:09:17.839604+00:00 0:00:00.862216 358529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T15:09:14.784924+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T14:00:00+00:00 PythonOperator 2023-03-24T15:08:57.339676+00:00 2023-03-24T15:09:01.370148+00:00 0:00:04.030472 358526 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T15:08:54.768527+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T13:00:00+00:00 TriggerDagRunOperator 2023-03-24T14:26:14.920472+00:00 2023-03-24T14:26:15.443485+00:00 0:00:00.523013 358518 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T14:26:12.026186+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T13:00:00+00:00 TriggerDagRunOperator 2023-03-24T14:26:14.641122+00:00 2023-03-24T14:26:15.167450+00:00 0:00:00.526328 358517 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T14:26:12.026160+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T13:00:00+00:00 EmrJobFlowSensor 2023-03-24T14:15:02.218770+00:00 2023-03-24T14:25:04.156197+00:00 0:10:01.937427 358512 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T14:14:59.944479+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T14:14:40.356057+00:00 2023-03-24T14:14:41.903128+00:00 0:00:01.547071 358509 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T14:14:37.914455+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T13:00:00+00:00 PythonOperator 2023-03-24T14:14:20.732458+00:00 2023-03-24T14:14:24.190461+00:00 0:00:03.458003 358506 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T14:14:17.902895+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T12:00:00+00:00 TriggerDagRunOperator 2023-03-24T13:16:40.820049+00:00 2023-03-24T13:16:41.476006+00:00 0:00:00.655957 358499 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T13:16:38.245102+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T12:00:00+00:00 TriggerDagRunOperator 2023-03-24T13:16:40.766475+00:00 2023-03-24T13:16:41.346286+00:00 0:00:00.579811 358498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T13:16:38.245131+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T12:00:00+00:00 EmrJobFlowSensor 2023-03-24T13:02:29.058443+00:00 2023-03-24T13:12:30.831594+00:00 0:10:01.773151 358492 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T13:02:26.318829+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T13:02:06.582419+00:00 2023-03-24T13:02:07.396107+00:00 0:00:00.813688 358490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T13:02:04.301223+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T12:00:00+00:00 PythonOperator 2023-03-24T13:01:46.442606+00:00 2023-03-24T13:01:49.568891+00:00 0:00:03.126285 358488 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T13:01:44.277760+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T11:00:00+00:00 TriggerDagRunOperator 2023-03-24T12:11:03.651323+00:00 2023-03-24T12:11:04.149725+00:00 0:00:00.498402 358479 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T12:11:01.121809+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T11:00:00+00:00 TriggerDagRunOperator 2023-03-24T12:11:03.529521+00:00 2023-03-24T12:11:04.006627+00:00 0:00:00.477106 358478 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T12:11:01.121844+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T11:00:00+00:00 EmrJobFlowSensor 2023-03-24T12:00:50.353773+00:00 2023-03-24T12:10:52.318765+00:00 0:10:01.964992 358471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T12:00:45.936899+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T12:00:26.160411+00:00 2023-03-24T12:00:26.978163+00:00 0:00:00.817752 358469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T12:00:23.887995+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T11:00:00+00:00 PythonOperator 2023-03-24T12:00:06.311193+00:00 2023-03-24T12:00:10.290233+00:00 0:00:03.979040 358467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T12:00:03.877526+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T10:00:00+00:00 TriggerDagRunOperator 2023-03-24T11:27:00.707114+00:00 2023-03-24T11:27:01.218023+00:00 0:00:00.510909 358459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T11:26:58.261473+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T10:00:00+00:00 TriggerDagRunOperator 2023-03-24T11:27:00.632655+00:00 2023-03-24T11:27:01.135075+00:00 0:00:00.502420 358458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T11:26:58.261503+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T10:00:00+00:00 EmrJobFlowSensor 2023-03-24T11:16:33.430003+00:00 2023-03-24T11:26:35.302574+00:00 0:10:01.872571 358454 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T11:16:30.981406+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T11:16:11.353957+00:00 2023-03-24T11:16:12.293442+00:00 0:00:00.939485 358451 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T11:16:08.963757+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T10:00:00+00:00 PythonOperator 2023-03-24T11:15:49.768521+00:00 2023-03-24T11:15:53.331558+00:00 0:00:03.563037 358448 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T11:15:46.947019+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T09:00:00+00:00 TriggerDagRunOperator 2023-03-24T10:41:31.507746+00:00 2023-03-24T10:41:31.979235+00:00 0:00:00.471489 358441 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T10:41:28.827083+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T09:00:00+00:00 TriggerDagRunOperator 2023-03-24T10:41:31.333944+00:00 2023-03-24T10:41:31.819840+00:00 0:00:00.485896 358440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T10:41:28.827054+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T09:00:00+00:00 EmrJobFlowSensor 2023-03-24T10:31:08.368817+00:00 2023-03-24T10:41:10.333813+00:00 0:10:01.964996 358435 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T10:31:06.067941+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T10:30:48.460588+00:00 2023-03-24T10:30:49.344864+00:00 0:00:00.884276 358433 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T10:30:46.049106+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T09:00:00+00:00 PythonOperator 2023-03-24T10:30:26.766992+00:00 2023-03-24T10:30:30.879874+00:00 0:00:04.112882 358429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T10:30:23.964048+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T08:00:00+00:00 TriggerDagRunOperator 2023-03-24T09:19:07.197014+00:00 2023-03-24T09:19:07.692068+00:00 0:00:00.495054 358420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T09:19:04.171811+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T08:00:00+00:00 TriggerDagRunOperator 2023-03-24T09:19:07.026313+00:00 2023-03-24T09:19:07.505977+00:00 0:00:00.479664 358419 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T09:19:04.171781+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T08:00:00+00:00 EmrJobFlowSensor 2023-03-24T09:06:25.756627+00:00 2023-03-24T09:16:27.725468+00:00 0:10:01.968841 358414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T09:06:23.188240+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T09:06:03.908352+00:00 2023-03-24T09:06:04.820837+00:00 0:00:00.912485 358411 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T09:06:01.174761+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T08:00:00+00:00 PythonOperator 2023-03-24T09:05:43.919365+00:00 2023-03-24T09:05:47.338444+00:00 0:00:03.419079 358408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T09:05:41.103187+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T07:00:00+00:00 TriggerDagRunOperator 2023-03-24T08:15:16.788594+00:00 2023-03-24T08:15:17.380652+00:00 0:00:00.592058 358402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T08:15:14.036253+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T07:00:00+00:00 TriggerDagRunOperator 2023-03-24T08:15:16.609404+00:00 2023-03-24T08:15:17.088832+00:00 0:00:00.479428 358401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T08:15:14.036282+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T07:00:00+00:00 EmrJobFlowSensor 2023-03-24T08:01:51.206037+00:00 2023-03-24T08:11:52.987846+00:00 0:10:01.781809 358396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T08:01:48.963552+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T08:01:29.359369+00:00 2023-03-24T08:01:30.235950+00:00 0:00:00.876581 358394 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T08:01:26.939486+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T07:00:00+00:00 PythonOperator 2023-03-24T08:00:15.855542+00:00 2023-03-24T08:00:19.058103+00:00 0:00:03.202561 358390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T08:00:13.596316+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T06:00:00+00:00 TriggerDagRunOperator 2023-03-24T07:11:59.771852+00:00 2023-03-24T07:12:00.349184+00:00 0:00:00.577332 358382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T07:11:57.096423+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T06:00:00+00:00 TriggerDagRunOperator 2023-03-24T07:11:59.576015+00:00 2023-03-24T07:12:00.144581+00:00 0:00:00.568566 358381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T07:11:57.096381+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T06:00:00+00:00 EmrJobFlowSensor 2023-03-24T07:01:47.712185+00:00 2023-03-24T07:11:49.613271+00:00 0:10:01.901086 358375 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T07:01:45.278088+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T07:01:25.543278+00:00 2023-03-24T07:01:26.778207+00:00 0:00:01.234929 358372 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T07:01:23.243965+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T06:00:00+00:00 PythonOperator 2023-03-24T07:01:03.769992+00:00 2023-03-24T07:01:07.249026+00:00 0:00:03.479034 358370 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T07:01:01.223180+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T05:00:00+00:00 TriggerDagRunOperator 2023-03-24T06:31:08.025249+00:00 2023-03-24T06:31:08.517642+00:00 0:00:00.492393 358362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T06:31:05.627117+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T05:00:00+00:00 TriggerDagRunOperator 2023-03-24T06:31:08.039386+00:00 2023-03-24T06:31:08.511932+00:00 0:00:00.472546 358361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T06:31:05.627090+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T05:00:00+00:00 EmrJobFlowSensor 2023-03-24T06:19:09.546488+00:00 2023-03-24T06:29:11.322173+00:00 0:10:01.775685 358358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T06:19:06.846885+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T06:18:49.488736+00:00 2023-03-24T06:18:50.420027+00:00 0:00:00.931291 358355 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T06:18:44.833668+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T05:00:00+00:00 PythonOperator 2023-03-24T06:18:25.063654+00:00 2023-03-24T06:18:28.275021+00:00 0:00:03.211367 358352 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T06:18:22.764964+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T04:00:00+00:00 TriggerDagRunOperator 2023-03-24T05:13:22.264774+00:00 2023-03-24T05:13:22.769896+00:00 0:00:00.505122 358342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T05:13:19.733764+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T04:00:00+00:00 TriggerDagRunOperator 2023-03-24T05:13:21.956946+00:00 2023-03-24T05:13:22.534388+00:00 0:00:00.577442 358341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T05:13:19.733801+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T04:00:00+00:00 EmrJobFlowSensor 2023-03-24T05:01:06.712889+00:00 2023-03-24T05:11:08.498267+00:00 0:10:01.785378 358334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T05:01:04.187767+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T05:00:46.305301+00:00 2023-03-24T05:00:47.166974+00:00 0:00:00.861673 358333 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T05:00:44.054342+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T04:00:00+00:00 PythonOperator 2023-03-24T05:00:24.849756+00:00 2023-03-24T05:00:28.323604+00:00 0:00:03.473848 358331 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T05:00:22.105221+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T03:00:00+00:00 TriggerDagRunOperator 2023-03-24T04:22:34.881041+00:00 2023-03-24T04:22:35.372439+00:00 0:00:00.491398 358321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T04:22:32.127003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T03:00:00+00:00 TriggerDagRunOperator 2023-03-24T04:22:34.689397+00:00 2023-03-24T04:22:35.158354+00:00 0:00:00.468957 358320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T04:22:32.127031+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T03:00:00+00:00 EmrJobFlowSensor 2023-03-24T04:09:26.597429+00:00 2023-03-24T04:19:28.314241+00:00 0:10:01.716812 358317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T04:09:24.121701+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T04:09:05.537547+00:00 2023-03-24T04:09:06.588343+00:00 0:00:01.050796 358314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T04:09:02.022584+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T03:00:00+00:00 PythonOperator 2023-03-24T04:08:43.665756+00:00 2023-03-24T04:08:50.384631+00:00 0:00:06.718875 358311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T04:08:39.956624+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T02:00:00+00:00 TriggerDagRunOperator 2023-03-24T03:25:16.528100+00:00 2023-03-24T03:25:17.017210+00:00 0:00:00.489110 358301 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T03:25:13.817219+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T02:00:00+00:00 TriggerDagRunOperator 2023-03-24T03:25:16.428340+00:00 2023-03-24T03:25:16.889091+00:00 0:00:00.460751 358300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T03:25:13.817249+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T02:00:00+00:00 EmrJobFlowSensor 2023-03-24T03:01:09.139848+00:00 2023-03-24T03:11:10.926762+00:00 0:10:01.786914 358293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T03:01:06.928532+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T03:00:47.167576+00:00 2023-03-24T03:00:48.018575+00:00 0:00:00.850999 358291 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T03:00:44.893989+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T02:00:00+00:00 PythonOperator 2023-03-24T03:00:23.336826+00:00 2023-03-24T03:00:27.327211+00:00 0:00:03.990385 358289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T03:00:20.991084+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T01:00:00+00:00 TriggerDagRunOperator 2023-03-24T02:14:26.308332+00:00 2023-03-24T02:14:26.790734+00:00 0:00:00.482402 358280 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T02:14:23.447770+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T01:00:00+00:00 TriggerDagRunOperator 2023-03-24T02:14:26.207137+00:00 2023-03-24T02:14:26.674213+00:00 0:00:00.467076 358279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T02:14:23.447798+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T01:00:00+00:00 EmrJobFlowSensor 2023-03-24T02:01:19.961483+00:00 2023-03-24T02:11:22.113771+00:00 0:10:02.152288 358272 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T02:01:17.508101+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T02:00:59.981550+00:00 2023-03-24T02:01:01.037720+00:00 0:00:01.056170 358271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T02:00:57.468176+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T01:00:00+00:00 PythonOperator 2023-03-24T02:00:38.095634+00:00 2023-03-24T02:00:44.116253+00:00 0:00:06.020619 358268 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T02:00:35.447466+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-24T00:00:00+00:00 TriggerDagRunOperator 2023-03-24T01:11:30.281913+00:00 2023-03-24T01:11:30.798395+00:00 0:00:00.516482 358253 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T01:11:27.949469+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-24T00:00:00+00:00 TriggerDagRunOperator 2023-03-24T01:11:30.176020+00:00 2023-03-24T01:11:30.664465+00:00 0:00:00.488445 358252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T01:11:27.949440+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-24T00:00:00+00:00 EmrJobFlowSensor 2023-03-24T01:01:06.663667+00:00 2023-03-24T01:11:08.503511+00:00 0:10:01.839844 358246 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T01:01:04.319341+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-24T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T01:00:46.514863+00:00 2023-03-24T01:00:47.325898+00:00 0:00:00.811035 358244 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T01:00:44.233127+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-24T00:00:00+00:00 PythonOperator 2023-03-24T01:00:24.496908+00:00 2023-03-24T01:00:30.345039+00:00 0:00:05.848131 358242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T01:00:22.213964+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T23:00:00+00:00 TriggerDagRunOperator 2023-03-24T00:14:24.284084+00:00 2023-03-24T00:14:24.781757+00:00 0:00:00.497673 358234 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T00:14:21.526666+00:00 2 default_pool