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-24T23:00:00+00:00 PythonOperator 2021-04-25T00:00:12.995663+00:00 2021-04-25T00:00:16.028064+00:00 0:00:03.032401 20910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T00:00:10.519567+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T22:00:00+00:00 EmrJobFlowSensor 2021-04-24T23:11:15.515171+00:00 2021-04-24T23:20:18.163812+00:00 0:09:02.648641 20908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T23:11:13.171932+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T22:00:00+00:00 EmrJobFlowSensor 2021-04-24T23:10:59.684154+00:00 2021-04-24T23:21:02.535017+00:00 0:10:02.850863 20907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T23:10:57.146363+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T23:10:53.301700+00:00 2021-04-24T23:10:54.993331+00:00 0:00:01.691631 20906 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T23:10:51.061165+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T23:10:39.502088+00:00 2021-04-24T23:10:41.300536+00:00 0:00:01.798448 20905 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T23:10:37.046528+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T22:00:00+00:00 PythonOperator 2021-04-24T23:10:33.195396+00:00 2021-04-24T23:10:36.137085+00:00 0:00:02.941689 20904 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T23:10:31.048587+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T22:00:00+00:00 PythonOperator 2021-04-24T23:10:17.168953+00:00 2021-04-24T23:10:20.421515+00:00 0:00:03.252562 20903 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T23:10:14.930291+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T22:00:00+00:00 TriggerDagRunOperator 2021-04-24T23:10:13.229640+00:00 2021-04-24T23:10:13.647805+00:00 0:00:00.418165 20902 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T23:10:10.927615+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T22:00:00+00:00 TriggerDagRunOperator 2021-04-24T23:10:13.234497+00:00 2021-04-24T23:10:13.794804+00:00 0:00:00.560307 20901 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T23:10:10.927588+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T22:05:00+00:00 EmrJobFlowSensor 2021-04-24T23:05:58.889667+00:00 2021-04-24T23:15:01.443474+00:00 0:09:02.553807 20900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T23:05:56.569656+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T23:05:38.930541+00:00 2021-04-24T23:05:40.548176+00:00 0:00:01.617635 20899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T23:05:36.546112+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T22:05:00+00:00 PythonOperator 2021-04-24T23:05:16.561871+00:00 2021-04-24T23:05:19.502116+00:00 0:00:02.940245 20898 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T23:05:14.432441+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-04-23T23:00:00+00:00 EmrJobFlowSensor 2021-04-24T23:00:56.100106+00:00 2021-04-24T23:09:58.691927+00:00 0:09:02.591821 20897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T23:00:54.003474+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T22:00:00+00:00 EmrJobFlowSensor 2021-04-24T23:00:52.305559+00:00 2021-04-24T23:09:55.187413+00:00 0:09:02.881854 20896 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T23:00:49.999587+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-04-23T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T23:00:36.339377+00:00 2021-04-24T23:00:38.049376+00:00 0:00:01.709999 20895 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T23:00:33.987058+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T23:00:30.502667+00:00 2021-04-24T23:00:32.182141+00:00 0:00:01.679474 20894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T23:00:28.064489+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-04-23T23:00:00+00:00 PythonOperator 2021-04-24T23:00:12.259924+00:00 2021-04-24T23:00:15.364713+00:00 0:00:03.104789 20893 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T23:00:09.979518+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T22:00:00+00:00 PythonOperator 2021-04-24T23:00:10.416221+00:00 2021-04-24T23:00:13.399665+00:00 0:00:02.983444 20892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T23:00:07.979862+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T21:00:00+00:00 EmrJobFlowSensor 2021-04-24T22:10:33.087189+00:00 2021-04-24T22:19:35.651134+00:00 0:09:02.563945 20890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T22:10:30.844543+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T21:00:00+00:00 EmrJobFlowSensor 2021-04-24T22:10:15.009320+00:00 2021-04-24T22:18:17.510925+00:00 0:08:02.501605 20889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T22:10:12.686385+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T22:10:02.934324+00:00 2021-04-24T22:10:04.775824+00:00 0:00:01.841500 20888 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T22:10:00.672520+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T22:09:52.882688+00:00 2021-04-24T22:09:54.533556+00:00 0:00:01.650868 20887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T22:09:50.665306+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T21:00:00+00:00 PythonOperator 2021-04-24T22:09:38.943505+00:00 2021-04-24T22:09:42.241559+00:00 0:00:03.298054 20886 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T22:09:36.656234+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T21:00:00+00:00 PythonOperator 2021-04-24T22:09:30.887079+00:00 2021-04-24T22:09:33.877830+00:00 0:00:02.990751 20885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T22:09:28.590620+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T21:00:00+00:00 TriggerDagRunOperator 2021-04-24T22:09:12.873187+00:00 2021-04-24T22:09:13.402698+00:00 0:00:00.529511 20884 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T22:09:10.517912+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T21:00:00+00:00 TriggerDagRunOperator 2021-04-24T22:09:12.767885+00:00 2021-04-24T22:09:13.170782+00:00 0:00:00.402897 20883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T22:09:10.517885+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T21:05:00+00:00 EmrJobFlowSensor 2021-04-24T22:06:58.473261+00:00 2021-04-24T22:16:01.148659+00:00 0:09:02.675398 20882 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T22:06:56.255453+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T22:06:36.370799+00:00 2021-04-24T22:06:38.046931+00:00 0:00:01.676132 20881 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T22:06:34.238188+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T21:05:00+00:00 PythonOperator 2021-04-24T22:05:20.576795+00:00 2021-04-24T22:05:23.507365+00:00 0:00:02.930570 20880 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T22:05:18.158907+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T21:00:00+00:00 EmrJobFlowSensor 2021-04-24T22:00:58.117834+00:00 2021-04-24T22:09:00.762487+00:00 0:08:02.644653 20879 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T22:00:55.769728+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T22:00:36.093100+00:00 2021-04-24T22:00:37.810094+00:00 0:00:01.716994 20878 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T22:00:33.763708+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T21:00:00+00:00 PythonOperator 2021-04-24T22:00:14.214905+00:00 2021-04-24T22:00:17.218766+00:00 0:00:03.003861 20877 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T22:00:11.651623+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T20:00:00+00:00 EmrJobFlowSensor 2021-04-24T21:11:39.700622+00:00 2021-04-24T21:20:42.359115+00:00 0:09:02.658493 20875 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T21:11:37.280827+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T20:00:00+00:00 EmrJobFlowSensor 2021-04-24T21:11:35.625430+00:00 2021-04-24T21:21:38.539912+00:00 0:10:02.914482 20874 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T21:11:33.277233+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T21:11:19.915913+00:00 2021-04-24T21:11:21.831684+00:00 0:00:01.915771 20873 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T21:11:17.265815+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T21:11:15.509927+00:00 2021-04-24T21:11:17.239306+00:00 0:00:01.729379 20872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T21:11:13.263758+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T20:00:00+00:00 PythonOperator 2021-04-24T21:10:47.420426+00:00 2021-04-24T21:10:50.360817+00:00 0:00:02.940391 20871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T21:10:45.233970+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T20:00:00+00:00 PythonOperator 2021-04-24T21:10:45.642716+00:00 2021-04-24T21:10:48.861988+00:00 0:00:03.219272 20870 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T21:10:43.236747+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T20:00:00+00:00 TriggerDagRunOperator 2021-04-24T21:10:33.594018+00:00 2021-04-24T21:10:34.162600+00:00 0:00:00.568582 20869 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T21:10:31.232077+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T20:00:00+00:00 TriggerDagRunOperator 2021-04-24T21:10:33.430970+00:00 2021-04-24T21:10:33.849686+00:00 0:00:00.418716 20868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T21:10:31.232127+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T20:05:00+00:00 EmrJobFlowSensor 2021-04-24T21:05:59.107589+00:00 2021-04-24T21:15:01.717097+00:00 0:09:02.609508 20867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T21:05:56.761338+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T21:05:38.908596+00:00 2021-04-24T21:05:40.568597+00:00 0:00:01.660001 20866 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T21:05:36.689198+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T20:05:00+00:00 PythonOperator 2021-04-24T21:05:14.999346+00:00 2021-04-24T21:05:17.953030+00:00 0:00:02.953684 20865 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T21:05:12.665761+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T20:00:00+00:00 EmrJobFlowSensor 2021-04-24T21:01:04.506536+00:00 2021-04-24T21:10:07.529073+00:00 0:09:03.022537 20864 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T21:01:02.260701+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T21:00:42.455431+00:00 2021-04-24T21:00:44.286453+00:00 0:00:01.831022 20863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T21:00:40.190571+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T20:00:00+00:00 PythonOperator 2021-04-24T21:00:22.777297+00:00 2021-04-24T21:00:25.769372+00:00 0:00:02.992075 20862 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T21:00:20.117592+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T19:00:00+00:00 EmrJobFlowSensor 2021-04-24T20:12:36.932773+00:00 2021-04-24T20:22:39.685217+00:00 0:10:02.752444 20860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T20:12:34.586446+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T20:12:14.731661+00:00 2021-04-24T20:12:16.463652+00:00 0:00:01.731991 20859 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T20:12:12.540297+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T19:00:00+00:00 EmrJobFlowSensor 2021-04-24T20:11:40.721250+00:00 2021-04-24T20:20:43.460444+00:00 0:09:02.739194 20858 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T20:11:38.515145+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T20:11:12.914759+00:00 2021-04-24T20:11:14.667243+00:00 0:00:01.752484 20857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T20:11:10.558850+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T19:00:00+00:00 PythonOperator 2021-04-24T20:10:48.707714+00:00 2021-04-24T20:10:51.952650+00:00 0:00:03.244936 20856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T20:10:46.421629+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T19:00:00+00:00 PythonOperator 2021-04-24T20:10:42.757430+00:00 2021-04-24T20:10:45.691033+00:00 0:00:02.933603 20855 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T20:10:40.426716+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T19:00:00+00:00 TriggerDagRunOperator 2021-04-24T20:10:26.807583+00:00 2021-04-24T20:10:27.330036+00:00 0:00:00.522453 20854 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T20:10:24.412938+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T19:00:00+00:00 TriggerDagRunOperator 2021-04-24T20:10:26.690189+00:00 2021-04-24T20:10:27.109389+00:00 0:00:00.419200 20853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T20:10:24.412905+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T19:05:00+00:00 EmrJobFlowSensor 2021-04-24T20:05:58.029900+00:00 2021-04-24T20:15:00.545073+00:00 0:09:02.515173 20852 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T20:05:55.867572+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T20:05:38.105655+00:00 2021-04-24T20:05:39.836966+00:00 0:00:01.731311 20851 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T20:05:35.852289+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T19:05:00+00:00 PythonOperator 2021-04-24T20:05:16.051661+00:00 2021-04-24T20:05:19.063951+00:00 0:00:03.012290 20850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T20:05:13.791528+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T19:00:00+00:00 EmrJobFlowSensor 2021-04-24T20:01:03.720931+00:00 2021-04-24T20:10:06.479297+00:00 0:09:02.758366 20849 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T20:01:01.488235+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T20:00:41.639870+00:00 2021-04-24T20:00:43.354442+00:00 0:00:01.714572 20848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T20:00:39.457353+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T19:00:00+00:00 PythonOperator 2021-04-24T20:00:21.742428+00:00 2021-04-24T20:00:24.774088+00:00 0:00:03.031660 20847 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T20:00:19.439348+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T18:00:00+00:00 EmrJobFlowSensor 2021-04-24T19:12:05.077562+00:00 2021-04-24T19:22:07.890181+00:00 0:10:02.812619 20845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T19:12:02.533648+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T18:00:00+00:00 EmrJobFlowSensor 2021-04-24T19:12:00.788721+00:00 2021-04-24T19:20:03.254475+00:00 0:08:02.465754 20844 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T19:11:58.543471+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T19:11:42.630913+00:00 2021-04-24T19:11:44.371154+00:00 0:00:01.740241 20843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T19:11:40.418676+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T19:11:38.670118+00:00 2021-04-24T19:11:40.428888+00:00 0:00:01.758770 20842 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T19:11:36.420935+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T18:00:00+00:00 PythonOperator 2021-04-24T19:11:20.693158+00:00 2021-04-24T19:11:23.895024+00:00 0:00:03.201866 20841 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T19:11:18.399621+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T18:00:00+00:00 PythonOperator 2021-04-24T19:11:16.794572+00:00 2021-04-24T19:11:19.768935+00:00 0:00:02.974363 20840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T19:11:14.461408+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T18:00:00+00:00 TriggerDagRunOperator 2021-04-24T19:10:59.075707+00:00 2021-04-24T19:10:59.613598+00:00 0:00:00.537891 20839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T19:10:56.389587+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T18:00:00+00:00 TriggerDagRunOperator 2021-04-24T19:10:58.975856+00:00 2021-04-24T19:10:59.396539+00:00 0:00:00.420683 20838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T19:10:56.389534+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T18:05:00+00:00 EmrJobFlowSensor 2021-04-24T19:05:48.280523+00:00 2021-04-24T19:13:50.686713+00:00 0:08:02.406190 20837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T19:05:45.933625+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T19:05:26.150400+00:00 2021-04-24T19:05:27.809225+00:00 0:00:01.658825 20836 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T19:05:23.913214+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T18:05:00+00:00 PythonOperator 2021-04-24T19:05:04.282645+00:00 2021-04-24T19:05:07.443160+00:00 0:00:03.160515 20835 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T19:05:01.969714+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T18:00:00+00:00 EmrJobFlowSensor 2021-04-24T19:00:48.159445+00:00 2021-04-24T19:10:51.113527+00:00 0:10:02.954082 20834 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T19:00:45.647284+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T19:00:25.780400+00:00 2021-04-24T19:00:27.459821+00:00 0:00:01.679421 20833 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T19:00:23.487350+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T18:00:00+00:00 PythonOperator 2021-04-24T19:00:06.108047+00:00 2021-04-24T19:00:09.128332+00:00 0:00:03.020285 20832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T19:00:03.470194+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T17:00:00+00:00 EmrJobFlowSensor 2021-04-24T18:11:25.260625+00:00 2021-04-24T18:20:27.877254+00:00 0:09:02.616629 20830 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T18:11:23.064394+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T17:00:00+00:00 EmrJobFlowSensor 2021-04-24T18:11:19.415607+00:00 2021-04-24T18:21:22.235431+00:00 0:10:02.819824 20829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T18:11:17.065110+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T18:11:05.504461+00:00 2021-04-24T18:11:07.275621+00:00 0:00:01.771160 20828 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T18:11:03.050714+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T18:10:59.391067+00:00 2021-04-24T18:11:01.082184+00:00 0:00:01.691117 20827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T18:10:57.040940+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T17:00:00+00:00 PythonOperator 2021-04-24T18:10:41.315261+00:00 2021-04-24T18:10:44.316211+00:00 0:00:03.000950 20826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T18:10:38.988878+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T17:00:00+00:00 PythonOperator 2021-04-24T18:10:37.336910+00:00 2021-04-24T18:10:40.528767+00:00 0:00:03.191857 20825 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T18:10:34.998283+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T17:00:00+00:00 TriggerDagRunOperator 2021-04-24T18:10:17.380501+00:00 2021-04-24T18:10:17.946105+00:00 0:00:00.565604 20824 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T18:10:14.959674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T17:00:00+00:00 TriggerDagRunOperator 2021-04-24T18:10:17.140781+00:00 2021-04-24T18:10:17.538638+00:00 0:00:00.397857 20823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T18:10:14.959724+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T17:05:00+00:00 EmrJobFlowSensor 2021-04-24T18:05:52.937503+00:00 2021-04-24T18:13:55.287646+00:00 0:08:02.350143 20822 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T18:05:50.576810+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T18:05:30.900562+00:00 2021-04-24T18:05:32.618847+00:00 0:00:01.718285 20821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T18:05:28.569602+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T17:05:00+00:00 PythonOperator 2021-04-24T18:05:08.868104+00:00 2021-04-24T18:05:11.780982+00:00 0:00:02.912878 20820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T18:05:06.554020+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T17:00:00+00:00 EmrJobFlowSensor 2021-04-24T18:01:04.917433+00:00 2021-04-24T18:10:07.782257+00:00 0:09:02.864824 20819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T18:01:02.167161+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T18:00:42.229219+00:00 2021-04-24T18:00:43.884489+00:00 0:00:01.655270 20818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T18:00:40.077959+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T17:00:00+00:00 PythonOperator 2021-04-24T18:00:22.317527+00:00 2021-04-24T18:00:25.317262+00:00 0:00:02.999735 20817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T18:00:20.060043+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T16:00:00+00:00 EmrJobFlowSensor 2021-04-24T17:11:29.158291+00:00 2021-04-24T17:20:31.819760+00:00 0:09:02.661469 20815 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T17:11:26.755799+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T16:00:00+00:00 EmrJobFlowSensor 2021-04-24T17:11:13.076412+00:00 2021-04-24T17:20:15.629142+00:00 0:09:02.552730 20814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T17:11:10.741604+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T17:11:09.060413+00:00 2021-04-24T17:11:10.832244+00:00 0:00:01.771831 20813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T17:11:06.737033+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T17:10:52.895314+00:00 2021-04-24T17:10:54.650702+00:00 0:00:01.755388 20812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T17:10:50.722327+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T16:00:00+00:00 PythonOperator 2021-04-24T17:10:47.080304+00:00 2021-04-24T17:10:50.015338+00:00 0:00:02.935034 20811 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T17:10:44.715979+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T16:00:00+00:00 PythonOperator 2021-04-24T17:10:31.512176+00:00 2021-04-24T17:10:34.679336+00:00 0:00:03.167160 20810 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T17:10:28.845394+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T16:00:00+00:00 TriggerDagRunOperator 2021-04-24T17:10:23.101721+00:00 2021-04-24T17:10:23.617470+00:00 0:00:00.515749 20809 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T17:10:20.686867+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T16:00:00+00:00 TriggerDagRunOperator 2021-04-24T17:10:22.994308+00:00 2021-04-24T17:10:23.395735+00:00 0:00:00.401427 20808 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T17:10:20.686837+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T16:05:00+00:00 EmrJobFlowSensor 2021-04-24T17:06:12.454957+00:00 2021-04-24T17:15:15.118516+00:00 0:09:02.663559 20807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T17:06:10.217775+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T17:05:52.507608+00:00 2021-04-24T17:05:54.181694+00:00 0:00:01.674086 20806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T17:05:50.202247+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T16:05:00+00:00 PythonOperator 2021-04-24T17:05:30.558822+00:00 2021-04-24T17:05:33.497309+00:00 0:00:02.938487 20805 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T17:05:28.340531+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T16:00:00+00:00 EmrJobFlowSensor 2021-04-24T17:01:00.420832+00:00 2021-04-24T17:10:03.372902+00:00 0:09:02.952070 20804 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T17:00:57.850947+00:00 2 default_pool