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 campaign-flow-job_v002 create_emr_steps 2021-04-07T21:00:00+00:00 PythonOperator 2021-04-07T22:00:19.137978+00:00 2021-04-07T22:00:21.913055+00:00 0:00:02.775077 14702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T22:00:16.369494+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T20:00:00+00:00 EmrJobFlowSensor 2021-04-07T21:12:06.424616+00:00 2021-04-07T21:22:09.254491+00:00 0:10:02.829875 14700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T21:12:04.238082+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T20:00:00+00:00 EmrJobFlowSensor 2021-04-07T21:11:58.464134+00:00 2021-04-07T21:21:01.201840+00:00 0:09:02.737706 14699 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T21:11:56.159070+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T21:11:46.630294+00:00 2021-04-07T21:11:48.308742+00:00 0:00:01.678448 14698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T21:11:44.163991+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T21:11:36.645856+00:00 2021-04-07T21:11:38.444260+00:00 0:00:01.798404 14697 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T21:11:34.174288+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T20:00:00+00:00 PythonOperator 2021-04-07T21:11:24.624484+00:00 2021-04-07T21:11:27.553116+00:00 0:00:02.928632 14696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T21:11:22.159637+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T20:00:00+00:00 PythonOperator 2021-04-07T21:11:16.417898+00:00 2021-04-07T21:11:19.273992+00:00 0:00:02.856094 14695 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T21:11:14.095692+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T20:00:00+00:00 TriggerDagRunOperator 2021-04-07T21:11:00.853827+00:00 2021-04-07T21:11:01.311484+00:00 0:00:00.457657 14694 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T21:10:58.072125+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T20:00:00+00:00 TriggerDagRunOperator 2021-04-07T21:11:00.714154+00:00 2021-04-07T21:11:01.264214+00:00 0:00:00.550060 14693 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T21:10:58.072091+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T20:05:00+00:00 EmrJobFlowSensor 2021-04-07T21:05:54.017907+00:00 2021-04-07T21:14:56.507398+00:00 0:09:02.489491 14692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T21:05:51.555504+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T21:05:31.859282+00:00 2021-04-07T21:05:33.521869+00:00 0:00:01.662587 14691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T21:05:29.551253+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T20:05:00+00:00 PythonOperator 2021-04-07T21:05:09.629695+00:00 2021-04-07T21:05:12.278978+00:00 0:00:02.649283 14690 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T21:05:07.436670+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T20:00:00+00:00 EmrJobFlowSensor 2021-04-07T21:01:51.323155+00:00 2021-04-07T21:10:54.000808+00:00 0:09:02.677653 14689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T21:01:49.112667+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T21:01:29.780138+00:00 2021-04-07T21:01:31.549016+00:00 0:00:01.768878 14688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T21:01:27.159823+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T20:00:00+00:00 PythonOperator 2021-04-07T21:01:09.653983+00:00 2021-04-07T21:01:12.545536+00:00 0:00:02.891553 14687 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T21:01:07.084024+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T19:00:00+00:00 EmrJobFlowSensor 2021-04-07T20:11:18.646722+00:00 2021-04-07T20:19:21.201984+00:00 0:08:02.555262 14685 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T20:11:16.174076+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T19:00:00+00:00 EmrJobFlowSensor 2021-04-07T20:11:12.493010+00:00 2021-04-07T20:22:15.695114+00:00 0:11:03.202104 14684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T20:11:10.133860+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T20:10:58.472970+00:00 2021-04-07T20:11:00.194687+00:00 0:00:01.721717 14683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T20:10:56.090986+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T20:10:52.314521+00:00 2021-04-07T20:10:54.241425+00:00 0:00:01.926904 14682 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T20:10:50.081262+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T19:00:00+00:00 PythonOperator 2021-04-07T20:10:36.273801+00:00 2021-04-07T20:10:38.968095+00:00 0:00:02.694294 14681 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T20:10:34.066766+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T19:00:00+00:00 PythonOperator 2021-04-07T20:10:30.552074+00:00 2021-04-07T20:10:33.528903+00:00 0:00:02.976829 14680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T20:10:28.065226+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T19:00:00+00:00 TriggerDagRunOperator 2021-04-07T20:10:16.677943+00:00 2021-04-07T20:10:17.257546+00:00 0:00:00.579603 14679 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T20:10:14.061865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T19:00:00+00:00 TriggerDagRunOperator 2021-04-07T20:10:16.476226+00:00 2021-04-07T20:10:16.903857+00:00 0:00:00.427631 14678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T20:10:14.061813+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T19:05:00+00:00 EmrJobFlowSensor 2021-04-07T20:05:48.131261+00:00 2021-04-07T20:14:50.784345+00:00 0:09:02.653084 14677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T20:05:45.744862+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T20:05:27.809265+00:00 2021-04-07T20:05:29.517573+00:00 0:00:01.708308 14676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T20:05:25.651562+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T19:05:00+00:00 PythonOperator 2021-04-07T20:05:05.773936+00:00 2021-04-07T20:05:08.423472+00:00 0:00:02.649536 14675 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T20:05:03.584142+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T19:00:00+00:00 EmrJobFlowSensor 2021-04-07T20:00:59.515432+00:00 2021-04-07T20:10:02.155427+00:00 0:09:02.639995 14674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T20:00:57.186833+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T20:00:39.655001+00:00 2021-04-07T20:00:41.466646+00:00 0:00:01.811645 14673 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T20:00:37.164904+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T19:00:00+00:00 PythonOperator 2021-04-07T20:00:15.552077+00:00 2021-04-07T20:00:18.300577+00:00 0:00:02.748500 14672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T20:00:13.143100+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T18:00:00+00:00 EmrJobFlowSensor 2021-04-07T19:10:33.383672+00:00 2021-04-07T19:20:36.269503+00:00 0:10:02.885831 14670 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T19:10:31.152781+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T18:00:00+00:00 EmrJobFlowSensor 2021-04-07T19:10:31.411679+00:00 2021-04-07T19:19:34.136448+00:00 0:09:02.724769 14669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T19:10:29.174872+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T19:10:11.308114+00:00 2021-04-07T19:10:13.116788+00:00 0:00:01.808674 14668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T19:10:09.114313+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T19:10:09.387489+00:00 2021-04-07T19:10:11.114913+00:00 0:00:01.727424 14667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T19:10:07.116825+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T18:00:00+00:00 PythonOperator 2021-04-07T19:09:49.816494+00:00 2021-04-07T19:09:52.876142+00:00 0:00:03.059648 14666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T19:09:47.102092+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T18:00:00+00:00 PythonOperator 2021-04-07T19:09:49.622129+00:00 2021-04-07T19:09:52.359347+00:00 0:00:02.737218 14665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T19:09:47.102143+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T18:00:00+00:00 TriggerDagRunOperator 2021-04-07T19:09:35.579268+00:00 2021-04-07T19:09:36.094768+00:00 0:00:00.515500 14664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T19:09:33.144106+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T18:00:00+00:00 TriggerDagRunOperator 2021-04-07T19:09:35.412941+00:00 2021-04-07T19:09:35.859532+00:00 0:00:00.446591 14663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T19:09:33.144076+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T18:05:00+00:00 EmrJobFlowSensor 2021-04-07T19:06:16.882261+00:00 2021-04-07T19:15:19.496963+00:00 0:09:02.614702 14662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T19:06:14.752870+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T19:05:49.022268+00:00 2021-04-07T19:05:50.747967+00:00 0:00:01.725699 14661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T19:05:46.636734+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T18:05:00+00:00 PythonOperator 2021-04-07T19:05:24.754121+00:00 2021-04-07T19:05:27.459951+00:00 0:00:02.705830 14660 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T19:05:22.615898+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T18:00:00+00:00 EmrJobFlowSensor 2021-04-07T19:01:10.311730+00:00 2021-04-07T19:09:12.844726+00:00 0:08:02.532996 14659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T19:01:08.159847+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T19:00:44.564817+00:00 2021-04-07T19:00:46.372692+00:00 0:00:01.807875 14658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T19:00:42.133849+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T18:00:00+00:00 PythonOperator 2021-04-07T19:00:14.495989+00:00 2021-04-07T19:00:17.246514+00:00 0:00:02.750525 14657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T19:00:12.109685+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T17:00:00+00:00 EmrJobFlowSensor 2021-04-07T18:11:09.893582+00:00 2021-04-07T18:22:12.827109+00:00 0:11:02.933527 14655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T18:11:07.675043+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T17:00:00+00:00 EmrJobFlowSensor 2021-04-07T18:10:55.862311+00:00 2021-04-07T18:19:58.443358+00:00 0:09:02.581047 14654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T18:10:53.602656+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T18:10:50.148475+00:00 2021-04-07T18:10:51.934596+00:00 0:00:01.786121 14653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T18:10:47.597099+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T18:10:33.930004+00:00 2021-04-07T18:10:35.695533+00:00 0:00:01.765529 14652 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T18:10:31.585915+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T17:00:00+00:00 PythonOperator 2021-04-07T18:10:27.856334+00:00 2021-04-07T18:10:30.947672+00:00 0:00:03.091338 14651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T18:10:25.545790+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T17:00:00+00:00 PythonOperator 2021-04-07T18:10:13.851731+00:00 2021-04-07T18:10:16.573404+00:00 0:00:02.721673 14650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T18:10:11.535302+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T17:00:00+00:00 TriggerDagRunOperator 2021-04-07T18:10:08.255226+00:00 2021-04-07T18:10:08.819947+00:00 0:00:00.564721 14649 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T18:10:05.583622+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T17:00:00+00:00 TriggerDagRunOperator 2021-04-07T18:10:08.017473+00:00 2021-04-07T18:10:08.432552+00:00 0:00:00.415079 14648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T18:10:05.583593+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T17:05:00+00:00 EmrJobFlowSensor 2021-04-07T18:05:49.677285+00:00 2021-04-07T18:14:52.244951+00:00 0:09:02.567666 14647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T18:05:47.344266+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T18:05:29.777645+00:00 2021-04-07T18:05:31.527467+00:00 0:00:01.749822 14646 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T18:05:27.270049+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T17:05:00+00:00 PythonOperator 2021-04-07T18:05:07.278024+00:00 2021-04-07T18:05:09.951342+00:00 0:00:02.673318 14645 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T18:05:05.168534+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T17:00:00+00:00 EmrJobFlowSensor 2021-04-07T18:00:55.225364+00:00 2021-04-07T18:09:58.156020+00:00 0:09:02.930656 14644 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T18:00:52.846194+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T18:00:35.159892+00:00 2021-04-07T18:00:36.882731+00:00 0:00:01.722839 14643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T18:00:32.760426+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T17:00:00+00:00 PythonOperator 2021-04-07T18:00:12.964119+00:00 2021-04-07T18:00:15.830327+00:00 0:00:02.866208 14642 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T18:00:10.689911+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T16:00:00+00:00 EmrJobFlowSensor 2021-04-07T17:16:42.927015+00:00 2021-04-07T17:26:45.662244+00:00 0:10:02.735229 14641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T17:16:40.279477+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T16:00:00+00:00 EmrJobFlowSensor 2021-04-07T17:16:42.620908+00:00 2021-04-07T17:25:45.522637+00:00 0:09:02.901729 14640 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T17:16:40.279510+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T17:16:22.860531+00:00 2021-04-07T17:16:24.676233+00:00 0:00:01.815702 14639 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T17:16:20.353249+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T17:16:22.685555+00:00 2021-04-07T17:16:24.468568+00:00 0:00:01.783013 14638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T17:16:20.353208+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T16:00:00+00:00 PythonOperator 2021-04-07T17:16:01.012238+00:00 2021-04-07T17:16:03.734135+00:00 0:00:02.721897 14637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T17:15:58.271730+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T16:00:00+00:00 PythonOperator 2021-04-07T17:16:01.041145+00:00 2021-04-07T17:16:04.144649+00:00 0:00:03.103504 14636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T17:15:58.271762+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T16:00:00+00:00 TriggerDagRunOperator 2021-04-07T17:15:42.611632+00:00 2021-04-07T17:15:43.152671+00:00 0:00:00.541039 14635 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T17:15:40.099725+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T16:00:00+00:00 TriggerDagRunOperator 2021-04-07T17:15:42.530451+00:00 2021-04-07T17:15:42.957005+00:00 0:00:00.426554 14634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T17:15:40.099696+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T16:05:00+00:00 EmrJobFlowSensor 2021-04-07T17:05:51.629834+00:00 2021-04-07T17:14:54.220550+00:00 0:09:02.590716 14632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T17:05:49.434165+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T17:05:31.843433+00:00 2021-04-07T17:05:33.511531+00:00 0:00:01.668098 14631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T17:05:29.495421+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T16:05:00+00:00 PythonOperator 2021-04-07T17:05:10.079523+00:00 2021-04-07T17:05:12.787091+00:00 0:00:02.707568 14630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T17:05:07.464762+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T16:00:00+00:00 EmrJobFlowSensor 2021-04-07T17:01:15.387521+00:00 2021-04-07T17:10:18.195064+00:00 0:09:02.807543 14629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T17:01:13.129107+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T17:00:53.311450+00:00 2021-04-07T17:00:54.998270+00:00 0:00:01.686820 14628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T17:00:51.086805+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T16:00:00+00:00 PythonOperator 2021-04-07T17:00:33.236605+00:00 2021-04-07T17:00:35.989833+00:00 0:00:02.753228 14627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T17:00:31.006505+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T15:00:00+00:00 EmrJobFlowSensor 2021-04-07T16:33:56.983140+00:00 2021-04-07T16:54:01.199776+00:00 0:20:04.216636 14626 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T16:33:54.606304+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T15:00:00+00:00 EmrJobFlowSensor 2021-04-07T16:33:40.896475+00:00 2021-04-07T16:42:43.581240+00:00 0:09:02.684765 14625 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T16:33:38.589747+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T16:33:35.015620+00:00 2021-04-07T16:33:36.698157+00:00 0:00:01.682537 14624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T16:33:32.644019+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T16:33:18.886927+00:00 2021-04-07T16:33:20.686412+00:00 0:00:01.799485 14623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T16:33:16.558281+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T15:00:00+00:00 PythonOperator 2021-04-07T16:33:14.791347+00:00 2021-04-07T16:33:17.548096+00:00 0:00:02.756749 14622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T16:33:12.559062+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T15:00:00+00:00 PythonOperator 2021-04-07T16:32:58.815327+00:00 2021-04-07T16:33:01.874366+00:00 0:00:03.059039 14621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T16:32:56.516227+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T15:00:00+00:00 TriggerDagRunOperator 2021-04-07T16:32:48.881489+00:00 2021-04-07T16:32:49.412674+00:00 0:00:00.531185 14620 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T16:32:46.499940+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T15:00:00+00:00 TriggerDagRunOperator 2021-04-07T16:32:48.798089+00:00 2021-04-07T16:32:49.222243+00:00 0:00:00.424154 14619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T16:32:46.499912+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T15:00:00+00:00 EmrJobFlowSensor 2021-04-07T16:11:10.696897+00:00 2021-04-07T16:32:14.954094+00:00 0:21:04.257197 14618 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T16:11:08.457687+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T15:05:00+00:00 EmrJobFlowSensor 2021-04-07T16:11:04.680961+00:00 2021-04-07T16:20:07.307864+00:00 0:09:02.626903 14617 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T16:11:02.501625+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T16:10:48.796587+00:00 2021-04-07T16:10:50.611899+00:00 0:00:01.815312 14616 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T16:10:46.435981+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T16:10:42.619793+00:00 2021-04-07T16:10:44.333094+00:00 0:00:01.713301 14615 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T16:10:40.436154+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T15:00:00+00:00 PythonOperator 2021-04-07T16:10:24.621203+00:00 2021-04-07T16:10:27.318326+00:00 0:00:02.697123 14614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T16:10:22.423724+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T15:05:00+00:00 PythonOperator 2021-04-07T16:10:21.061547+00:00 2021-04-07T16:10:23.869285+00:00 0:00:02.807738 14613 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T16:10:18.420375+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T14:00:00+00:00 EmrJobFlowSensor 2021-04-07T15:12:09.894485+00:00 2021-04-07T15:22:12.690800+00:00 0:10:02.796315 14611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T15:12:07.717718+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T14:00:00+00:00 EmrJobFlowSensor 2021-04-07T15:11:58.001811+00:00 2021-04-07T15:21:00.701623+00:00 0:09:02.699812 14610 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T15:11:55.710107+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T15:11:50.193247+00:00 2021-04-07T15:11:51.920438+00:00 0:00:01.727191 14609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T15:11:47.697671+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T15:11:37.930898+00:00 2021-04-07T15:11:39.650691+00:00 0:00:01.719793 14608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T15:11:35.688866+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T14:00:00+00:00 PythonOperator 2021-04-07T15:11:28.580470+00:00 2021-04-07T15:11:31.530056+00:00 0:00:02.949586 14607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T15:11:25.621427+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T14:00:00+00:00 PythonOperator 2021-04-07T15:11:15.931972+00:00 2021-04-07T15:11:18.737883+00:00 0:00:02.805911 14606 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T15:11:13.608289+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T14:00:00+00:00 TriggerDagRunOperator 2021-04-07T15:11:06.199579+00:00 2021-04-07T15:11:06.636861+00:00 0:00:00.437282 14605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T15:11:03.656827+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T14:00:00+00:00 TriggerDagRunOperator 2021-04-07T15:11:06.227702+00:00 2021-04-07T15:11:06.791951+00:00 0:00:00.564249 14604 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T15:11:03.656874+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T14:05:00+00:00 EmrJobFlowSensor 2021-04-07T15:05:55.367491+00:00 2021-04-07T15:14:58.174032+00:00 0:09:02.806541 14603 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T15:05:53.129880+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T15:05:33.266154+00:00 2021-04-07T15:05:34.889491+00:00 0:00:01.623337 14602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T15:05:31.111088+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T14:05:00+00:00 PythonOperator 2021-04-07T15:05:13.267404+00:00 2021-04-07T15:05:15.946557+00:00 0:00:02.679153 14601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T15:05:11.092703+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T14:00:00+00:00 EmrJobFlowSensor 2021-04-07T15:00:48.933780+00:00 2021-04-07T15:10:51.770513+00:00 0:10:02.836733 14600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T15:00:46.736687+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T15:00:29.132317+00:00 2021-04-07T15:00:30.953273+00:00 0:00:01.820956 14599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T15:00:26.717955+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T14:00:00+00:00 PythonOperator 2021-04-07T15:00:07.380463+00:00 2021-04-07T15:00:10.147688+00:00 0:00:02.767225 14598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T15:00:04.618281+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T13:00:00+00:00 EmrJobFlowSensor 2021-04-07T14:10:16.487135+00:00 2021-04-07T14:19:19.218512+00:00 0:09:02.731377 14596 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T14:10:14.196365+00:00 2 default_pool