Task Instances

  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 booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-04T12:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T13:11:57.205572+00:00 2021-07-04T13:11:59.011023+00:00 0:00:01.805451 49699 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T13:11:54.600020+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-04T12:00:00+00:00 PythonOperator 2021-07-04T13:11:49.168309+00:00 2021-07-04T13:11:52.761175+00:00 0:00:03.592866 49698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T13:11:46.659359+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-04T12:00:00+00:00 PythonOperator 2021-07-04T13:11:35.336959+00:00 2021-07-04T13:11:39.030074+00:00 0:00:03.693115 49697 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T13:11:32.571709+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-04T12:00:00+00:00 TriggerDagRunOperator 2021-07-04T13:11:26.905391+00:00 2021-07-04T13:11:27.413403+00:00 0:00:00.508012 49696 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T13:11:24.565486+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-04T12:00:00+00:00 TriggerDagRunOperator 2021-07-04T13:11:26.795579+00:00 2021-07-04T13:11:27.203434+00:00 0:00:00.407855 49695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T13:11:24.565452+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-04T12:05:00+00:00 EmrJobFlowSensor 2021-07-04T13:05:52.156477+00:00 2021-07-04T13:14:54.736537+00:00 0:09:02.580060 49694 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T13:05:50.006365+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-04T12:05:00+00:00 EmrCreateJobFlowOperator 2021-07-04T13:05:26.070558+00:00 2021-07-04T13:05:27.700081+00:00 0:00:01.629523 49693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T13:05:23.956769+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-04T12:05:00+00:00 PythonOperator 2021-07-04T13:05:04.141323+00:00 2021-07-04T13:05:07.523253+00:00 0:00:03.381930 49692 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T13:05:01.938003+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-04T12:00:00+00:00 EmrJobFlowSensor 2021-07-04T13:01:00.181144+00:00 2021-07-04T13:11:03.159699+00:00 0:10:02.978555 49691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T13:00:57.741077+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-04T12:00:00+00:00 EmrJobFlowSensor 2021-07-04T13:00:49.986812+00:00 2021-07-04T13:10:52.875060+00:00 0:10:02.888248 49690 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T13:00:47.571800+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-04T12:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T13:00:37.903632+00:00 2021-07-04T13:00:39.705388+00:00 0:00:01.801756 49689 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-04T13:00:35.500694+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-04T12:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T13:00:27.705181+00:00 2021-07-04T13:00:29.384951+00:00 0:00:01.679770 49688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T13:00:25.489303+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-04T12:00:00+00:00 PythonOperator 2021-07-04T13:00:17.690493+00:00 2021-07-04T13:00:21.134278+00:00 0:00:03.443785 49687 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-04T13:00:15.469149+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-04T12:00:00+00:00 PythonOperator 2021-07-04T13:00:07.695028+00:00 2021-07-04T13:00:11.335659+00:00 0:00:03.640631 49686 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T13:00:05.457934+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-04T11:00:00+00:00 EmrJobFlowSensor 2021-07-04T12:11:17.582446+00:00 2021-07-04T12:20:20.438838+00:00 0:09:02.856392 49684 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T12:11:15.346181+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-04T11:00:00+00:00 EmrJobFlowSensor 2021-07-04T12:11:11.500143+00:00 2021-07-04T12:21:14.397858+00:00 0:10:02.897715 49683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T12:11:09.339137+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-04T11:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T12:10:55.563218+00:00 2021-07-04T12:10:57.330688+00:00 0:00:01.767470 49682 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T12:10:53.307403+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-04T11:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T12:10:51.585566+00:00 2021-07-04T12:10:53.311066+00:00 0:00:01.725500 49681 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T12:10:49.301021+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-04T11:00:00+00:00 PythonOperator 2021-07-04T12:10:34.552651+00:00 2021-07-04T12:10:38.127283+00:00 0:00:03.574632 49680 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T12:10:31.346662+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-04T11:00:00+00:00 PythonOperator 2021-07-04T12:10:29.757838+00:00 2021-07-04T12:10:34.399525+00:00 0:00:04.641687 49679 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T12:10:27.291835+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-04T11:00:00+00:00 TriggerDagRunOperator 2021-07-04T12:10:07.834803+00:00 2021-07-04T12:10:08.383622+00:00 0:00:00.548819 49678 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T12:10:05.265127+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-04T11:00:00+00:00 TriggerDagRunOperator 2021-07-04T12:10:07.441353+00:00 2021-07-04T12:10:07.839966+00:00 0:00:00.398613 49677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T12:10:05.265159+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-04T11:05:00+00:00 EmrJobFlowSensor 2021-07-04T12:05:49.490743+00:00 2021-07-04T12:13:52.046964+00:00 0:08:02.556221 49676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T12:05:46.955406+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-04T11:05:00+00:00 EmrCreateJobFlowOperator 2021-07-04T12:05:27.121957+00:00 2021-07-04T12:05:28.960479+00:00 0:00:01.838522 49675 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T12:05:24.874722+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-04T11:05:00+00:00 PythonOperator 2021-07-04T12:05:07.188658+00:00 2021-07-04T12:05:10.198095+00:00 0:00:03.009437 49674 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T12:05:04.785899+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-04T11:00:00+00:00 EmrJobFlowSensor 2021-07-04T12:01:04.722720+00:00 2021-07-04T12:11:07.837453+00:00 0:10:03.114733 49673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T12:01:02.510794+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-04T11:00:00+00:00 EmrJobFlowSensor 2021-07-04T12:01:01.105563+00:00 2021-07-04T12:10:03.916715+00:00 0:09:02.811152 49672 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T12:00:58.658972+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-04T11:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T12:00:42.720198+00:00 2021-07-04T12:00:44.436884+00:00 0:00:01.716686 49671 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T12:00:40.487498+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-04T11:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T12:00:40.710844+00:00 2021-07-04T12:00:42.515975+00:00 0:00:01.805131 49670 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-04T12:00:38.484392+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-04T11:00:00+00:00 PythonOperator 2021-07-04T12:00:21.751456+00:00 2021-07-04T12:00:25.532538+00:00 0:00:03.781082 49669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T12:00:18.469418+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-04T11:00:00+00:00 PythonOperator 2021-07-04T12:00:19.615899+00:00 2021-07-04T12:00:23.874823+00:00 0:00:04.258924 49668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-04T12:00:16.476016+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-04T10:00:00+00:00 EmrJobFlowSensor 2021-07-04T11:11:09.287352+00:00 2021-07-04T11:21:12.187801+00:00 0:10:02.900449 49666 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T11:11:06.995316+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-04T10:00:00+00:00 EmrJobFlowSensor 2021-07-04T11:10:59.208911+00:00 2021-07-04T11:20:01.969684+00:00 0:09:02.760773 49665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T11:10:56.926670+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-04T10:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T11:10:47.110109+00:00 2021-07-04T11:10:48.938501+00:00 0:00:01.828392 49664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T11:10:44.917631+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-04T10:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T11:10:39.115418+00:00 2021-07-04T11:10:40.793123+00:00 0:00:01.677705 49663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T11:10:36.911797+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-04T10:00:00+00:00 PythonOperator 2021-07-04T11:10:25.321873+00:00 2021-07-04T11:10:29.221066+00:00 0:00:03.899193 49662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T11:10:22.963377+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-04T10:00:00+00:00 PythonOperator 2021-07-04T11:10:17.823973+00:00 2021-07-04T11:10:21.263994+00:00 0:00:03.440021 49661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T11:10:14.947036+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-04T10:00:00+00:00 TriggerDagRunOperator 2021-07-04T11:10:10.020622+00:00 2021-07-04T11:10:10.396896+00:00 0:00:00.376274 49660 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T11:10:06.946160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-04T10:00:00+00:00 TriggerDagRunOperator 2021-07-04T11:10:09.618565+00:00 2021-07-04T11:10:10.149845+00:00 0:00:00.531280 49659 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T11:10:06.946111+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-04T10:05:00+00:00 EmrJobFlowSensor 2021-07-04T11:06:02.759394+00:00 2021-07-04T11:15:05.363029+00:00 0:09:02.603635 49658 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T11:06:00.470664+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-04T10:05:00+00:00 EmrCreateJobFlowOperator 2021-07-04T11:05:40.739893+00:00 2021-07-04T11:05:42.409685+00:00 0:00:01.669792 49657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T11:05:38.459966+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-04T10:05:00+00:00 PythonOperator 2021-07-04T11:05:18.714705+00:00 2021-07-04T11:05:22.087700+00:00 0:00:03.372995 49656 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T11:05:16.359811+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-04T10:00:00+00:00 EmrJobFlowSensor 2021-07-04T11:00:58.454157+00:00 2021-07-04T11:10:01.227662+00:00 0:09:02.773505 49655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T11:00:55.975931+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-04T10:00:00+00:00 EmrJobFlowSensor 2021-07-04T11:00:56.165080+00:00 2021-07-04T11:11:59.547811+00:00 0:11:03.382731 49654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T11:00:53.977282+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-04T10:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T11:00:36.294199+00:00 2021-07-04T11:00:38.085116+00:00 0:00:01.790917 49653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-04T11:00:33.956057+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-04T10:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T11:00:36.097811+00:00 2021-07-04T11:00:37.804868+00:00 0:00:01.707057 49652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T11:00:33.956089+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-04T10:00:00+00:00 PythonOperator 2021-07-04T11:00:14.374716+00:00 2021-07-04T11:00:18.007116+00:00 0:00:03.632400 49651 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-04T11:00:11.957429+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-04T10:00:00+00:00 PythonOperator 2021-07-04T11:00:12.617841+00:00 2021-07-04T11:00:16.004330+00:00 0:00:03.386489 49650 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T11:00:09.977237+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-04T09:00:00+00:00 EmrJobFlowSensor 2021-07-04T10:11:30.548723+00:00 2021-07-04T10:21:33.371324+00:00 0:10:02.822601 49648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T10:11:28.062413+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-04T09:00:00+00:00 EmrJobFlowSensor 2021-07-04T10:11:22.110863+00:00 2021-07-04T10:19:24.840073+00:00 0:08:02.729210 49647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T10:11:19.930922+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-04T09:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T10:11:08.458352+00:00 2021-07-04T10:11:10.214011+00:00 0:00:01.755659 49646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T10:11:05.925409+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-04T09:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T10:11:00.381282+00:00 2021-07-04T10:11:02.167959+00:00 0:00:01.786677 49645 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T10:10:57.917436+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-04T09:00:00+00:00 PythonOperator 2021-07-04T10:10:46.290139+00:00 2021-07-04T10:10:49.903069+00:00 0:00:03.612930 49644 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T10:10:43.964724+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-04T09:00:00+00:00 PythonOperator 2021-07-04T10:10:38.294424+00:00 2021-07-04T10:10:41.910445+00:00 0:00:03.616021 49643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T10:10:35.966085+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-04T09:00:00+00:00 TriggerDagRunOperator 2021-07-04T10:10:26.416140+00:00 2021-07-04T10:10:26.921673+00:00 0:00:00.505533 49642 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T10:10:23.958958+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-04T09:00:00+00:00 TriggerDagRunOperator 2021-07-04T10:10:26.323259+00:00 2021-07-04T10:10:26.719523+00:00 0:00:00.396264 49641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T10:10:23.958998+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-04T09:05:00+00:00 EmrJobFlowSensor 2021-07-04T10:05:55.649125+00:00 2021-07-04T10:13:58.257185+00:00 0:08:02.608060 49640 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T10:05:53.425035+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-04T09:05:00+00:00 EmrCreateJobFlowOperator 2021-07-04T10:05:33.514557+00:00 2021-07-04T10:05:35.206930+00:00 0:00:01.692373 49639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T10:05:31.406169+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-04T09:05:00+00:00 PythonOperator 2021-07-04T10:05:11.581582+00:00 2021-07-04T10:05:15.210684+00:00 0:00:03.629102 49638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T10:05:09.389957+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-04T09:00:00+00:00 EmrJobFlowSensor 2021-07-04T10:01:07.615538+00:00 2021-07-04T10:11:10.356453+00:00 0:10:02.740915 49637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T10:01:04.943938+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-04T09:00:00+00:00 EmrJobFlowSensor 2021-07-04T10:01:05.301656+00:00 2021-07-04T10:10:08.347670+00:00 0:09:03.046014 49636 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T10:01:02.943544+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-04T09:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T10:00:46.953780+00:00 2021-07-04T10:00:48.594056+00:00 0:00:01.640276 49635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T10:00:44.801413+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-04T09:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T10:00:43.037057+00:00 2021-07-04T10:00:44.765682+00:00 0:00:01.728625 49634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-04T10:00:40.790478+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-04T09:00:00+00:00 PythonOperator 2021-07-04T10:00:25.069419+00:00 2021-07-04T10:00:28.675854+00:00 0:00:03.606435 49633 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T10:00:22.742602+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-04T09:00:00+00:00 PythonOperator 2021-07-04T10:00:23.168832+00:00 2021-07-04T10:00:26.603068+00:00 0:00:03.434236 49632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-04T10:00:20.725413+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-04T08:00:00+00:00 EmrJobFlowSensor 2021-07-04T09:11:38.341611+00:00 2021-07-04T09:19:40.958865+00:00 0:08:02.617254 49630 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T09:11:35.658577+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-04T08:00:00+00:00 EmrJobFlowSensor 2021-07-04T09:11:30.166613+00:00 2021-07-04T09:21:32.971384+00:00 0:10:02.804771 49629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T09:11:27.751252+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-04T08:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T09:11:16.283059+00:00 2021-07-04T09:11:18.025530+00:00 0:00:01.742471 49628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T09:11:13.572018+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-04T08:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T09:11:09.688142+00:00 2021-07-04T09:11:11.460095+00:00 0:00:01.771953 49627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T09:11:07.512285+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-04T08:00:00+00:00 PythonOperator 2021-07-04T09:10:55.648792+00:00 2021-07-04T09:10:59.263612+00:00 0:00:03.614820 49626 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T09:10:53.452333+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-04T08:00:00+00:00 PythonOperator 2021-07-04T09:10:47.661540+00:00 2021-07-04T09:10:51.281367+00:00 0:00:03.619827 49625 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T09:10:45.443093+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-04T08:00:00+00:00 TriggerDagRunOperator 2021-07-04T09:10:23.913637+00:00 2021-07-04T09:10:24.332425+00:00 0:00:00.418788 49624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T09:10:21.423089+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-04T08:00:00+00:00 TriggerDagRunOperator 2021-07-04T09:10:23.837648+00:00 2021-07-04T09:10:24.364945+00:00 0:00:00.527297 49623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T09:10:21.423122+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-04T08:05:00+00:00 EmrJobFlowSensor 2021-07-04T09:05:59.372959+00:00 2021-07-04T09:14:01.867328+00:00 0:08:02.494369 49622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T09:05:57.129779+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-04T08:05:00+00:00 EmrCreateJobFlowOperator 2021-07-04T09:05:37.223479+00:00 2021-07-04T09:05:38.844787+00:00 0:00:01.621308 49621 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T09:05:35.114278+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-04T08:05:00+00:00 PythonOperator 2021-07-04T09:05:17.156459+00:00 2021-07-04T09:05:20.722006+00:00 0:00:03.565547 49620 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T09:05:15.092316+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-04T08:00:00+00:00 EmrJobFlowSensor 2021-07-04T09:01:06.613322+00:00 2021-07-04T09:10:09.253962+00:00 0:09:02.640640 49619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T09:01:04.487253+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-04T08:00:00+00:00 EmrJobFlowSensor 2021-07-04T09:00:56.606475+00:00 2021-07-04T09:10:59.449115+00:00 0:10:02.842640 49618 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T09:00:54.434605+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-04T08:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T09:00:44.757296+00:00 2021-07-04T09:00:46.603737+00:00 0:00:01.846441 49617 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-04T09:00:42.425035+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-04T08:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T09:00:34.897992+00:00 2021-07-04T09:00:36.579077+00:00 0:00:01.681085 49616 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T09:00:32.544873+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-04T08:00:00+00:00 PythonOperator 2021-07-04T09:00:24.633564+00:00 2021-07-04T09:00:28.228518+00:00 0:00:03.594954 49615 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-04T09:00:22.413020+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-04T08:00:00+00:00 PythonOperator 2021-07-04T09:00:12.677756+00:00 2021-07-04T09:00:16.327190+00:00 0:00:03.649434 49614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T09:00:10.394977+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-04T07:00:00+00:00 EmrJobFlowSensor 2021-07-04T08:11:26.131950+00:00 2021-07-04T08:20:28.870861+00:00 0:09:02.738911 49612 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T08:11:23.865252+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-04T07:00:00+00:00 EmrJobFlowSensor 2021-07-04T08:11:12.558937+00:00 2021-07-04T08:21:15.456195+00:00 0:10:02.897258 49611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T08:11:09.865607+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T08:11:04.060481+00:00 2021-07-04T08:11:05.814924+00:00 0:00:01.754443 49610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T08:11:01.811567+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T08:10:50.275109+00:00 2021-07-04T08:10:52.092574+00:00 0:00:01.817465 49609 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T08:10:47.861815+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-04T07:00:00+00:00 PythonOperator 2021-07-04T08:10:44.061753+00:00 2021-07-04T08:10:48.039746+00:00 0:00:03.977993 49608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T08:10:41.792596+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-04T07:00:00+00:00 PythonOperator 2021-07-04T08:10:27.990708+00:00 2021-07-04T08:10:31.419681+00:00 0:00:03.428973 49607 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T08:10:25.733999+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-04T07:00:00+00:00 TriggerDagRunOperator 2021-07-04T08:10:24.088144+00:00 2021-07-04T08:10:24.583445+00:00 0:00:00.495301 49606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T08:10:21.726084+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-04T07:00:00+00:00 TriggerDagRunOperator 2021-07-04T08:10:23.997770+00:00 2021-07-04T08:10:24.377074+00:00 0:00:00.379304 49605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T08:10:21.726054+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-04T07:05:00+00:00 EmrJobFlowSensor 2021-07-04T08:05:56.166739+00:00 2021-07-04T08:14:58.954135+00:00 0:09:02.787396 49604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T08:05:53.463192+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-04T07:05:00+00:00 EmrCreateJobFlowOperator 2021-07-04T08:05:33.443009+00:00 2021-07-04T08:05:35.099424+00:00 0:00:01.656415 49603 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T08:05:31.342265+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-04T07:05:00+00:00 PythonOperator 2021-07-04T08:05:11.502255+00:00 2021-07-04T08:05:14.923544+00:00 0:00:03.421289 49602 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T08:05:09.322033+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-04T07:00:00+00:00 EmrJobFlowSensor 2021-07-04T08:01:05.442203+00:00 2021-07-04T08:11:08.311814+00:00 0:10:02.869611 49601 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T08:01:02.961941+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-04T07:00:00+00:00 EmrJobFlowSensor 2021-07-04T08:00:59.111736+00:00 2021-07-04T08:10:01.840639+00:00 0:09:02.728903 49600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T08:00:56.953751+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T08:00:45.283258+00:00 2021-07-04T08:00:47.037023+00:00 0:00:01.753765 49599 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T08:00:42.939014+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T08:00:39.270908+00:00 2021-07-04T08:00:40.991026+00:00 0:00:01.720118 49598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-04T08:00:36.935138+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-04T07:00:00+00:00 PythonOperator 2021-07-04T08:00:23.085761+00:00 2021-07-04T08:00:26.673199+00:00 0:00:03.587438 49597 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T08:00:20.885268+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-04T07:00:00+00:00 PythonOperator 2021-07-04T08:00:17.217867+00:00 2021-07-04T08:00:20.591132+00:00 0:00:03.373265 49596 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-04T08:00:14.880364+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-04T06:00:00+00:00 EmrJobFlowSensor 2021-07-04T07:10:29.670027+00:00 2021-07-04T07:19:32.270431+00:00 0:09:02.600404 49594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T07:10:27.435156+00:00 2 default_pool