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-history-job_v002 check_cluster_status 2021-05-08T22:00:00+00:00 EmrJobFlowSensor 2021-05-08T23:11:03.453940+00:00 2021-05-08T23:20:06.056412+00:00 0:09:02.602472 25990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T23:11:01.233978+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T23:10:47.505982+00:00 2021-05-08T23:10:49.173107+00:00 0:00:01.667125 25989 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T23:10:45.180995+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T23:10:41.291618+00:00 2021-05-08T23:10:42.937836+00:00 0:00:01.646218 25988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T23:10:39.158031+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T22:00:00+00:00 PythonOperator 2021-05-08T23:10:25.570960+00:00 2021-05-08T23:10:29.067624+00:00 0:00:03.496664 25987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T23:10:23.174655+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T22:00:00+00:00 PythonOperator 2021-05-08T23:10:19.644951+00:00 2021-05-08T23:10:22.724951+00:00 0:00:03.080000 25986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T23:10:17.099770+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T22:00:00+00:00 TriggerDagRunOperator 2021-05-08T23:10:11.583401+00:00 2021-05-08T23:10:12.163927+00:00 0:00:00.580526 25985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T23:10:09.169629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T22:00:00+00:00 TriggerDagRunOperator 2021-05-08T23:10:11.455366+00:00 2021-05-08T23:10:11.875563+00:00 0:00:00.420197 25984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T23:10:09.169589+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T22:05:00+00:00 EmrJobFlowSensor 2021-05-08T23:06:10.851586+00:00 2021-05-08T23:14:13.502863+00:00 0:08:02.651277 25983 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T23:06:08.455450+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T22:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T23:05:44.494701+00:00 2021-05-08T23:05:46.139036+00:00 0:00:01.644335 25982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T23:05:42.298293+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T22:05:00+00:00 PythonOperator 2021-05-08T23:05:18.642279+00:00 2021-05-08T23:05:21.639203+00:00 0:00:02.996924 25981 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T23:05:16.289837+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-05-07T23:00:00+00:00 EmrJobFlowSensor 2021-05-08T23:01:03.838198+00:00 2021-05-08T23:09:06.439387+00:00 0:08:02.601189 25980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T23:01:01.670670+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T22:00:00+00:00 EmrJobFlowSensor 2021-05-08T23:00:50.191338+00:00 2021-05-08T23:09:52.846641+00:00 0:09:02.655303 25979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T23:00:47.661414+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-05-07T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T23:00:41.753267+00:00 2021-05-08T23:00:43.417411+00:00 0:00:01.664144 25978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T23:00:39.653497+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T23:00:28.375082+00:00 2021-05-08T23:00:30.061291+00:00 0:00:01.686209 25977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T23:00:25.563000+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-05-07T23:00:00+00:00 PythonOperator 2021-05-08T23:00:19.931942+00:00 2021-05-08T23:00:23.041444+00:00 0:00:03.109502 25976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T23:00:17.564184+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T22:00:00+00:00 PythonOperator 2021-05-08T23:00:06.016047+00:00 2021-05-08T23:00:09.162547+00:00 0:00:03.146500 25975 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T23:00:03.578766+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T21:00:00+00:00 EmrJobFlowSensor 2021-05-08T22:23:30.675755+00:00 2021-05-08T22:32:33.289675+00:00 0:09:02.613920 25974 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T22:23:28.552262+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T21:00:00+00:00 EmrJobFlowSensor 2021-05-08T22:23:16.714127+00:00 2021-05-08T22:33:19.724595+00:00 0:10:03.010468 25973 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T22:23:14.529996+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T22:23:08.785852+00:00 2021-05-08T22:23:10.506938+00:00 0:00:01.721086 25972 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T22:23:06.518552+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T22:22:56.687928+00:00 2021-05-08T22:22:58.387205+00:00 0:00:01.699277 25971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T22:22:54.501625+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T21:00:00+00:00 PythonOperator 2021-05-08T22:22:46.614960+00:00 2021-05-08T22:22:49.698541+00:00 0:00:03.083581 25970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T22:22:44.494928+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T21:00:00+00:00 PythonOperator 2021-05-08T22:22:34.917505+00:00 2021-05-08T22:22:38.202944+00:00 0:00:03.285439 25969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T22:22:32.563820+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T21:00:00+00:00 TriggerDagRunOperator 2021-05-08T22:22:23.313139+00:00 2021-05-08T22:22:23.752925+00:00 0:00:00.439786 25968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T22:22:20.461679+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T21:00:00+00:00 TriggerDagRunOperator 2021-05-08T22:22:23.323843+00:00 2021-05-08T22:22:23.918953+00:00 0:00:00.595110 25967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T22:22:20.461633+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T21:05:00+00:00 EmrJobFlowSensor 2021-05-08T22:05:54.970685+00:00 2021-05-08T22:13:57.510459+00:00 0:08:02.539774 25965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T22:05:52.551001+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T21:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T22:05:32.824595+00:00 2021-05-08T22:05:34.543450+00:00 0:00:01.718855 25964 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T22:05:30.468515+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T21:05:00+00:00 PythonOperator 2021-05-08T22:05:10.549146+00:00 2021-05-08T22:05:13.652124+00:00 0:00:03.102978 25963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T22:05:08.397637+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T21:00:00+00:00 EmrJobFlowSensor 2021-05-08T22:00:58.078640+00:00 2021-05-08T22:22:02.509657+00:00 0:21:04.431017 25962 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T22:00:55.927653+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T22:00:36.103674+00:00 2021-05-08T22:00:37.805932+00:00 0:00:01.702258 25961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T22:00:33.844214+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T21:00:00+00:00 PythonOperator 2021-05-08T22:00:16.254057+00:00 2021-05-08T22:00:19.336429+00:00 0:00:03.082372 25960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T22:00:13.853374+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T20:00:00+00:00 EmrJobFlowSensor 2021-05-08T21:12:16.492774+00:00 2021-05-08T21:20:18.954567+00:00 0:08:02.461793 25958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T21:12:14.400821+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T20:00:00+00:00 EmrJobFlowSensor 2021-05-08T21:12:03.182938+00:00 2021-05-08T21:21:05.837170+00:00 0:09:02.654232 25957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T21:12:00.471866+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T21:11:54.522428+00:00 2021-05-08T21:11:56.316692+00:00 0:00:01.794264 25956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T21:11:52.333332+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T21:11:40.941567+00:00 2021-05-08T21:11:42.634210+00:00 0:00:01.692643 25955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T21:11:38.334772+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T20:00:00+00:00 PythonOperator 2021-05-08T21:11:32.505657+00:00 2021-05-08T21:11:35.531716+00:00 0:00:03.026059 25954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T21:11:30.317426+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T20:00:00+00:00 PythonOperator 2021-05-08T21:11:19.255009+00:00 2021-05-08T21:11:22.683989+00:00 0:00:03.428980 25953 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T21:11:16.383452+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T20:00:00+00:00 TriggerDagRunOperator 2021-05-08T21:11:12.583079+00:00 2021-05-08T21:11:13.120783+00:00 0:00:00.537704 25952 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T21:11:10.299581+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T20:00:00+00:00 TriggerDagRunOperator 2021-05-08T21:11:12.519947+00:00 2021-05-08T21:11:12.972123+00:00 0:00:00.452176 25951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T21:11:10.299540+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T20:05:00+00:00 EmrJobFlowSensor 2021-05-08T21:06:02.164851+00:00 2021-05-08T21:14:04.716368+00:00 0:08:02.551517 25950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T21:05:59.746066+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T20:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T21:05:39.872734+00:00 2021-05-08T21:05:41.688123+00:00 0:00:01.815389 25949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T21:05:37.506176+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T20:05:00+00:00 PythonOperator 2021-05-08T21:05:19.642279+00:00 2021-05-08T21:05:22.668258+00:00 0:00:03.025979 25948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T21:05:17.475645+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T20:00:00+00:00 EmrJobFlowSensor 2021-05-08T21:00:50.898101+00:00 2021-05-08T21:10:53.686056+00:00 0:10:02.787955 25947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T21:00:48.801814+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T21:00:29.427475+00:00 2021-05-08T21:00:31.223982+00:00 0:00:01.796507 25946 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T21:00:26.850817+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T20:00:00+00:00 PythonOperator 2021-05-08T21:00:08.984246+00:00 2021-05-08T21:00:12.084932+00:00 0:00:03.100686 25945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T21:00:06.713395+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T19:00:00+00:00 EmrJobFlowSensor 2021-05-08T20:10:31.891760+00:00 2021-05-08T20:18:34.343764+00:00 0:08:02.452004 25943 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T20:10:29.274380+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T19:00:00+00:00 EmrJobFlowSensor 2021-05-08T20:10:29.670113+00:00 2021-05-08T20:20:32.601639+00:00 0:10:02.931526 25942 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T20:10:27.260249+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T20:10:09.645170+00:00 2021-05-08T20:10:11.320959+00:00 0:00:01.675789 25941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T20:10:07.126229+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T20:10:07.242151+00:00 2021-05-08T20:10:09.310342+00:00 0:00:02.068191 25940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T20:10:05.120760+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T19:00:00+00:00 PythonOperator 2021-05-08T20:09:47.446552+00:00 2021-05-08T20:09:50.547791+00:00 0:00:03.101239 25939 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T20:09:45.117065+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T19:00:00+00:00 PythonOperator 2021-05-08T20:09:45.615901+00:00 2021-05-08T20:09:48.938464+00:00 0:00:03.322563 25938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T20:09:43.167912+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T19:00:00+00:00 TriggerDagRunOperator 2021-05-08T20:09:29.903500+00:00 2021-05-08T20:09:30.414713+00:00 0:00:00.511213 25937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T20:09:27.147557+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T19:00:00+00:00 TriggerDagRunOperator 2021-05-08T20:09:29.459622+00:00 2021-05-08T20:09:29.856442+00:00 0:00:00.396820 25936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T20:09:27.147604+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T19:05:00+00:00 EmrJobFlowSensor 2021-05-08T20:06:35.008330+00:00 2021-05-08T20:15:37.752578+00:00 0:09:02.744248 25935 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T20:06:32.746723+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T19:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T20:06:14.855555+00:00 2021-05-08T20:06:16.532136+00:00 0:00:01.676581 25934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T20:06:12.723952+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T19:05:00+00:00 PythonOperator 2021-05-08T20:05:53.076815+00:00 2021-05-08T20:05:56.147236+00:00 0:00:03.070421 25933 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T20:05:50.841541+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T19:00:00+00:00 EmrJobFlowSensor 2021-05-08T20:01:06.321392+00:00 2021-05-08T20:09:08.845806+00:00 0:08:02.524414 25932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T20:01:04.186154+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T20:00:44.206182+00:00 2021-05-08T20:00:45.919911+00:00 0:00:01.713729 25931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T20:00:42.125363+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T19:00:00+00:00 PythonOperator 2021-05-08T20:00:24.524390+00:00 2021-05-08T20:00:27.561382+00:00 0:00:03.036992 25930 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T20:00:22.103058+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T18:00:00+00:00 EmrJobFlowSensor 2021-05-08T19:11:12.836000+00:00 2021-05-08T19:21:15.589951+00:00 0:10:02.753951 25928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T19:11:10.594478+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T18:00:00+00:00 EmrJobFlowSensor 2021-05-08T19:11:06.946652+00:00 2021-05-08T19:20:09.759402+00:00 0:09:02.812750 25927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T19:11:04.661501+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T19:10:53.161985+00:00 2021-05-08T19:10:54.850757+00:00 0:00:01.688772 25926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T19:10:50.645122+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T19:10:46.864714+00:00 2021-05-08T19:10:48.562962+00:00 0:00:01.698248 25925 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T19:10:44.561522+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T18:00:00+00:00 PythonOperator 2021-05-08T19:10:31.081545+00:00 2021-05-08T19:10:34.457408+00:00 0:00:03.375863 25924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T19:10:28.472549+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T18:00:00+00:00 PythonOperator 2021-05-08T19:10:24.656377+00:00 2021-05-08T19:10:27.792336+00:00 0:00:03.135959 25923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T19:10:22.363891+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T18:00:00+00:00 TriggerDagRunOperator 2021-05-08T19:10:18.856540+00:00 2021-05-08T19:10:19.359582+00:00 0:00:00.503042 25922 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T19:10:16.341684+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T18:00:00+00:00 TriggerDagRunOperator 2021-05-08T19:10:18.585327+00:00 2021-05-08T19:10:19.013680+00:00 0:00:00.428353 25921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T19:10:16.341633+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T18:05:00+00:00 EmrJobFlowSensor 2021-05-08T19:05:51.997477+00:00 2021-05-08T19:14:54.520556+00:00 0:09:02.523079 25920 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T19:05:49.857056+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T18:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T19:05:30.296804+00:00 2021-05-08T19:05:31.924877+00:00 0:00:01.628073 25919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T19:05:27.768355+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T18:05:00+00:00 PythonOperator 2021-05-08T19:05:07.968139+00:00 2021-05-08T19:05:11.044246+00:00 0:00:03.076107 25918 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T19:05:05.667376+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T18:00:00+00:00 EmrJobFlowSensor 2021-05-08T19:01:05.246966+00:00 2021-05-08T19:10:08.041545+00:00 0:09:02.794579 25917 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T19:01:03.096774+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T19:00:41.097674+00:00 2021-05-08T19:00:42.977299+00:00 0:00:01.879625 25916 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T19:00:38.892598+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T18:00:00+00:00 PythonOperator 2021-05-08T19:00:21.214986+00:00 2021-05-08T19:00:24.486948+00:00 0:00:03.271962 25915 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T19:00:18.836239+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T17:00:00+00:00 EmrJobFlowSensor 2021-05-08T18:10:19.485009+00:00 2021-05-08T18:19:22.136948+00:00 0:09:02.651939 25913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T18:10:17.067549+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T17:00:00+00:00 EmrJobFlowSensor 2021-05-08T18:10:11.387526+00:00 2021-05-08T18:19:14.052828+00:00 0:09:02.665302 25912 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T18:10:09.142051+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T18:09:57.932445+00:00 2021-05-08T18:09:59.711358+00:00 0:00:01.778913 25911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T18:09:55.054258+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T18:09:49.413249+00:00 2021-05-08T18:09:51.112604+00:00 0:00:01.699355 25910 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T18:09:46.994587+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T17:00:00+00:00 PythonOperator 2021-05-08T18:09:35.321845+00:00 2021-05-08T18:09:38.410249+00:00 0:00:03.088404 25909 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T18:09:32.967599+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T17:00:00+00:00 PythonOperator 2021-05-08T18:09:27.334079+00:00 2021-05-08T18:09:30.668606+00:00 0:00:03.334527 25908 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T18:09:24.970424+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T17:00:00+00:00 TriggerDagRunOperator 2021-05-08T18:09:15.488322+00:00 2021-05-08T18:09:16.068665+00:00 0:00:00.580343 25907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T18:09:12.967270+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T17:00:00+00:00 TriggerDagRunOperator 2021-05-08T18:09:15.333195+00:00 2021-05-08T18:09:15.858048+00:00 0:00:00.524853 25906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T18:09:12.967318+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T17:05:00+00:00 EmrJobFlowSensor 2021-05-08T18:05:54.992307+00:00 2021-05-08T18:14:57.632523+00:00 0:09:02.640216 25905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T18:05:52.551535+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T18:05:32.975825+00:00 2021-05-08T18:05:34.735656+00:00 0:00:01.759831 25904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T18:05:30.446471+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T17:05:00+00:00 PythonOperator 2021-05-08T18:05:10.694460+00:00 2021-05-08T18:05:13.732671+00:00 0:00:03.038211 25903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T18:05:08.446563+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T17:00:00+00:00 EmrJobFlowSensor 2021-05-08T18:01:06.319315+00:00 2021-05-08T18:09:09.019159+00:00 0:08:02.699844 25902 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T18:01:03.841408+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T18:00:45.821644+00:00 2021-05-08T18:00:47.658697+00:00 0:00:01.837053 25901 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T18:00:43.581082+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T17:00:00+00:00 PythonOperator 2021-05-08T18:00:23.829642+00:00 2021-05-08T18:00:27.007743+00:00 0:00:03.178101 25900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T18:00:21.560484+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T16:00:00+00:00 EmrJobFlowSensor 2021-05-08T17:11:33.797187+00:00 2021-05-08T17:20:36.585198+00:00 0:09:02.788011 25898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T17:11:31.546297+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T16:00:00+00:00 EmrJobFlowSensor 2021-05-08T17:11:25.853009+00:00 2021-05-08T17:20:28.779070+00:00 0:09:02.926061 25897 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T17:11:23.515852+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T17:11:11.680777+00:00 2021-05-08T17:11:13.528556+00:00 0:00:01.847779 25896 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T17:11:09.505719+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T17:11:03.712935+00:00 2021-05-08T17:11:05.415882+00:00 0:00:01.702947 25895 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T17:11:01.485656+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T16:00:00+00:00 PythonOperator 2021-05-08T17:10:50.109313+00:00 2021-05-08T17:10:53.239312+00:00 0:00:03.129999 25894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T17:10:47.413320+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T16:00:00+00:00 PythonOperator 2021-05-08T17:10:41.476646+00:00 2021-05-08T17:10:44.817245+00:00 0:00:03.340599 25893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T17:10:39.403636+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T16:00:00+00:00 TriggerDagRunOperator 2021-05-08T17:10:25.701053+00:00 2021-05-08T17:10:26.242759+00:00 0:00:00.541706 25892 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T17:10:23.395331+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T16:00:00+00:00 TriggerDagRunOperator 2021-05-08T17:10:25.557141+00:00 2021-05-08T17:10:25.999325+00:00 0:00:00.442184 25891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T17:10:23.395383+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T16:05:00+00:00 EmrJobFlowSensor 2021-05-08T17:06:05.174289+00:00 2021-05-08T17:15:07.965584+00:00 0:09:02.791295 25890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T17:06:02.898387+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T17:05:42.988264+00:00 2021-05-08T17:05:44.666202+00:00 0:00:01.677938 25889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T17:05:40.822734+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T16:05:00+00:00 PythonOperator 2021-05-08T17:05:23.052895+00:00 2021-05-08T17:05:26.057699+00:00 0:00:03.004804 25888 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T17:05:20.803375+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T16:00:00+00:00 EmrJobFlowSensor 2021-05-08T17:00:58.796006+00:00 2021-05-08T17:10:01.536722+00:00 0:09:02.740716 25887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T17:00:56.463640+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T17:00:38.566994+00:00 2021-05-08T17:00:40.283367+00:00 0:00:01.716373 25886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T17:00:36.318497+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T16:00:00+00:00 PythonOperator 2021-05-08T17:00:16.785830+00:00 2021-05-08T17:00:19.909006+00:00 0:00:03.123176 25885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T17:00:14.350868+00:00 2 default_pool