Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_emr_steps 2021-04-03T01:00:00+00:00 PythonOperator 2021-04-03T02:00:24.814119+00:00 2021-04-03T02:00:27.520809+00:00 0:00:02.706690 12958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T02:00:22.244771+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T00:00:00+00:00 TriggerDagRunOperator 2021-04-03T01:10:27.441658+00:00 2021-04-03T01:10:28.125551+00:00 0:00:00.683893 12950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T01:10:25.107104+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T00:00:00+00:00 TriggerDagRunOperator 2021-04-03T01:10:27.450930+00:00 2021-04-03T01:10:28.000622+00:00 0:00:00.549692 12949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T01:10:25.107069+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T00:00:00+00:00 EmrJobFlowSensor 2021-04-03T01:01:14.736846+00:00 2021-04-03T01:10:17.574999+00:00 0:09:02.838153 12945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T01:01:12.425874+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T01:00:46.664507+00:00 2021-04-03T01:00:48.472139+00:00 0:00:01.807632 12944 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T01:00:44.398816+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T00:00:00+00:00 PythonOperator 2021-04-03T01:00:22.688779+00:00 2021-04-03T01:00:25.482156+00:00 0:00:02.793377 12943 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T01:00:20.363246+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T23:00:00+00:00 TriggerDagRunOperator 2021-04-03T00:11:12.565227+00:00 2021-04-03T00:11:12.986042+00:00 0:00:00.420815 12935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T00:11:10.128929+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T23:00:00+00:00 TriggerDagRunOperator 2021-04-03T00:11:12.416304+00:00 2021-04-03T00:11:12.982504+00:00 0:00:00.566200 12934 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T00:11:10.128893+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T23:00:00+00:00 EmrJobFlowSensor 2021-04-03T00:00:53.523872+00:00 2021-04-03T00:10:56.494672+00:00 0:10:02.970800 12930 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T00:00:51.142776+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T00:00:29.715731+00:00 2021-04-03T00:00:31.535049+00:00 0:00:01.819318 12929 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T00:00:27.168383+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T23:00:00+00:00 PythonOperator 2021-04-03T00:00:07.871825+00:00 2021-04-03T00:00:10.749458+00:00 0:00:02.877633 12928 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T00:00:05.156050+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T22:00:00+00:00 TriggerDagRunOperator 2021-04-02T23:17:30.234485+00:00 2021-04-02T23:17:30.837058+00:00 0:00:00.602573 12920 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T23:17:27.678290+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T22:00:00+00:00 TriggerDagRunOperator 2021-04-02T23:17:29.977521+00:00 2021-04-02T23:17:30.443109+00:00 0:00:00.465588 12919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T23:17:27.678257+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T22:00:00+00:00 EmrJobFlowSensor 2021-04-02T23:01:04.807316+00:00 2021-04-02T23:17:08.566611+00:00 0:16:03.759295 12915 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T23:01:02.142996+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T23:00:28.181302+00:00 2021-04-02T23:00:29.928177+00:00 0:00:01.746875 12914 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T23:00:25.993474+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T22:00:00+00:00 PythonOperator 2021-04-02T23:00:06.345058+00:00 2021-04-02T23:00:09.206301+00:00 0:00:02.861243 12913 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T23:00:03.948883+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T21:00:00+00:00 TriggerDagRunOperator 2021-04-02T22:09:57.037542+00:00 2021-04-02T22:09:57.463003+00:00 0:00:00.425461 12905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T22:09:54.540859+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T21:00:00+00:00 TriggerDagRunOperator 2021-04-02T22:09:57.019898+00:00 2021-04-02T22:09:57.583202+00:00 0:00:00.563304 12904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T22:09:54.540902+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T21:00:00+00:00 EmrJobFlowSensor 2021-04-02T22:00:50.087422+00:00 2021-04-02T22:09:52.871288+00:00 0:09:02.783866 12900 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T22:00:47.633296+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T22:00:27.968615+00:00 2021-04-02T22:00:29.793497+00:00 0:00:01.824882 12899 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T22:00:25.616597+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T21:00:00+00:00 PythonOperator 2021-04-02T22:00:08.100707+00:00 2021-04-02T22:00:10.948328+00:00 0:00:02.847621 12898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T22:00:05.595839+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T20:00:00+00:00 TriggerDagRunOperator 2021-04-02T21:10:15.730954+00:00 2021-04-02T21:10:16.243981+00:00 0:00:00.513027 12890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T21:10:13.346431+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T20:00:00+00:00 TriggerDagRunOperator 2021-04-02T21:10:15.616795+00:00 2021-04-02T21:10:16.025114+00:00 0:00:00.408319 12889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T21:10:13.346463+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T20:00:00+00:00 EmrJobFlowSensor 2021-04-02T21:00:48.429424+00:00 2021-04-02T21:09:51.207973+00:00 0:09:02.778549 12885 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T21:00:46.123217+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T21:00:26.550735+00:00 2021-04-02T21:00:28.294207+00:00 0:00:01.743472 12884 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T21:00:24.161031+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T20:00:00+00:00 PythonOperator 2021-04-02T21:00:04.463371+00:00 2021-04-02T21:00:07.288605+00:00 0:00:02.825234 12883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T21:00:02.090151+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T19:00:00+00:00 TriggerDagRunOperator 2021-04-02T20:10:12.460962+00:00 2021-04-02T20:10:12.903318+00:00 0:00:00.442356 12875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T20:10:10.124778+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T19:00:00+00:00 TriggerDagRunOperator 2021-04-02T20:10:12.421947+00:00 2021-04-02T20:10:13.004360+00:00 0:00:00.582413 12874 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T20:10:10.124746+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T19:00:00+00:00 EmrJobFlowSensor 2021-04-02T20:01:01.711435+00:00 2021-04-02T20:10:04.489489+00:00 0:09:02.778054 12870 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T20:00:59.364463+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T20:00:37.611124+00:00 2021-04-02T20:00:39.312916+00:00 0:00:01.701792 12869 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T20:00:35.369649+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T19:00:00+00:00 PythonOperator 2021-04-02T20:00:15.725665+00:00 2021-04-02T20:00:18.592541+00:00 0:00:02.866876 12868 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T20:00:13.321533+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T18:00:00+00:00 TriggerDagRunOperator 2021-04-02T19:18:58.873203+00:00 2021-04-02T19:18:59.585849+00:00 0:00:00.712646 12860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T19:18:56.062195+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T18:00:00+00:00 TriggerDagRunOperator 2021-04-02T19:18:58.431977+00:00 2021-04-02T19:18:58.995048+00:00 0:00:00.563071 12859 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T19:18:56.062162+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T18:00:00+00:00 EmrJobFlowSensor 2021-04-02T19:00:48.297950+00:00 2021-04-02T19:18:52.069667+00:00 0:18:03.771717 12855 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T19:00:46.143603+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T19:00:26.397648+00:00 2021-04-02T19:00:28.086356+00:00 0:00:01.688708 12854 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T19:00:24.131313+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T18:00:00+00:00 PythonOperator 2021-04-02T19:00:04.624755+00:00 2021-04-02T19:00:07.376553+00:00 0:00:02.751798 12853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T19:00:02.100097+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T17:00:00+00:00 TriggerDagRunOperator 2021-04-02T18:11:29.483618+00:00 2021-04-02T18:11:30.024138+00:00 0:00:00.540520 12845 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T18:11:27.010492+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T17:00:00+00:00 TriggerDagRunOperator 2021-04-02T18:11:29.205336+00:00 2021-04-02T18:11:29.683369+00:00 0:00:00.478033 12844 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T18:11:27.010519+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T17:00:00+00:00 EmrJobFlowSensor 2021-04-02T18:01:04.536764+00:00 2021-04-02T18:11:07.389877+00:00 0:10:02.853113 12840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T18:01:02.185583+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T18:00:42.447669+00:00 2021-04-02T18:00:44.264936+00:00 0:00:01.817267 12839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T18:00:40.143616+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T17:00:00+00:00 PythonOperator 2021-04-02T18:00:22.660492+00:00 2021-04-02T18:00:25.532310+00:00 0:00:02.871818 12838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T18:00:20.035276+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T16:00:00+00:00 TriggerDagRunOperator 2021-04-02T17:11:40.866091+00:00 2021-04-02T17:11:41.393569+00:00 0:00:00.527478 12830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T17:11:38.593507+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T16:00:00+00:00 TriggerDagRunOperator 2021-04-02T17:11:40.853763+00:00 2021-04-02T17:11:41.255276+00:00 0:00:00.401513 12829 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T17:11:38.593539+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T16:00:00+00:00 EmrJobFlowSensor 2021-04-02T17:01:07.818691+00:00 2021-04-02T17:11:10.893781+00:00 0:10:03.075090 12825 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T17:01:05.618694+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T17:00:45.835118+00:00 2021-04-02T17:00:47.580065+00:00 0:00:01.744947 12824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T17:00:43.596017+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T16:00:00+00:00 PythonOperator 2021-04-02T17:00:24.370566+00:00 2021-04-02T17:00:27.258741+00:00 0:00:02.888175 12823 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T17:00:21.584024+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T15:00:00+00:00 TriggerDagRunOperator 2021-04-02T16:10:59.874190+00:00 2021-04-02T16:11:00.384339+00:00 0:00:00.510149 12815 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T16:10:57.309479+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T15:00:00+00:00 TriggerDagRunOperator 2021-04-02T16:10:59.484879+00:00 2021-04-02T16:10:59.890548+00:00 0:00:00.405669 12814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T16:10:57.309452+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T15:00:00+00:00 EmrJobFlowSensor 2021-04-02T16:00:46.697294+00:00 2021-04-02T16:10:49.544609+00:00 0:10:02.847315 12810 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T16:00:44.421251+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T16:00:26.614369+00:00 2021-04-02T16:00:28.336483+00:00 0:00:01.722114 12809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T16:00:24.402097+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T15:00:00+00:00 PythonOperator 2021-04-02T16:00:05.107472+00:00 2021-04-02T16:00:07.995766+00:00 0:00:02.888294 12808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T16:00:02.385758+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T14:00:00+00:00 TriggerDagRunOperator 2021-04-02T15:09:15.732656+00:00 2021-04-02T15:09:16.244342+00:00 0:00:00.511686 12800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T15:09:13.346760+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T14:00:00+00:00 TriggerDagRunOperator 2021-04-02T15:09:15.725679+00:00 2021-04-02T15:09:16.379065+00:00 0:00:00.653386 12799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T15:09:13.346727+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T14:00:00+00:00 EmrJobFlowSensor 2021-04-02T15:00:58.621024+00:00 2021-04-02T15:09:01.257629+00:00 0:08:02.636605 12795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T15:00:56.427880+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T15:00:38.894777+00:00 2021-04-02T15:00:40.720580+00:00 0:00:01.825803 12794 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T15:00:36.407657+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T14:00:00+00:00 PythonOperator 2021-04-02T15:00:16.910955+00:00 2021-04-02T15:00:19.791853+00:00 0:00:02.880898 12793 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T15:00:14.456112+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T13:00:00+00:00 TriggerDagRunOperator 2021-04-02T14:13:40.544413+00:00 2021-04-02T14:13:41.068122+00:00 0:00:00.523709 12786 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T14:13:37.696784+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T13:00:00+00:00 TriggerDagRunOperator 2021-04-02T14:13:40.428379+00:00 2021-04-02T14:13:40.891127+00:00 0:00:00.462748 12785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T14:13:37.696816+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T13:00:00+00:00 EmrJobFlowSensor 2021-04-02T14:00:50.385122+00:00 2021-04-02T14:10:53.370776+00:00 0:10:02.985654 12780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T14:00:48.157528+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T14:00:28.602753+00:00 2021-04-02T14:00:30.427232+00:00 0:00:01.824479 12779 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T14:00:26.173297+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T13:00:00+00:00 PythonOperator 2021-04-02T14:00:08.397686+00:00 2021-04-02T14:00:11.154235+00:00 0:00:02.756549 12778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T14:00:06.149043+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T12:00:00+00:00 TriggerDagRunOperator 2021-04-02T13:11:27.328018+00:00 2021-04-02T13:11:27.841904+00:00 0:00:00.513886 12771 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T13:11:24.250815+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T12:00:00+00:00 TriggerDagRunOperator 2021-04-02T13:11:27.112662+00:00 2021-04-02T13:11:27.544956+00:00 0:00:00.432294 12770 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T13:11:24.250859+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T12:00:00+00:00 EmrJobFlowSensor 2021-04-02T13:01:06.130918+00:00 2021-04-02T13:11:09.022565+00:00 0:10:02.891647 12765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T13:01:03.891095+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T13:00:44.389820+00:00 2021-04-02T13:00:46.212868+00:00 0:00:01.823048 12764 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T13:00:41.846724+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T12:00:00+00:00 PythonOperator 2021-04-02T13:00:24.269985+00:00 2021-04-02T13:00:27.014844+00:00 0:00:02.744859 12763 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T13:00:21.828320+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T11:00:00+00:00 TriggerDagRunOperator 2021-04-02T12:10:23.014831+00:00 2021-04-02T12:10:23.611397+00:00 0:00:00.596566 12756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T12:10:20.648208+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T11:00:00+00:00 TriggerDagRunOperator 2021-04-02T12:10:22.961913+00:00 2021-04-02T12:10:23.717311+00:00 0:00:00.755398 12755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T12:10:20.648172+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T11:00:00+00:00 EmrJobFlowSensor 2021-04-02T12:00:55.835701+00:00 2021-04-02T12:09:58.483537+00:00 0:09:02.647836 12750 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T12:00:53.497831+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T12:00:33.748113+00:00 2021-04-02T12:00:35.619507+00:00 0:00:01.871394 12749 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T12:00:31.467926+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T11:00:00+00:00 PythonOperator 2021-04-02T12:00:13.711940+00:00 2021-04-02T12:00:16.552626+00:00 0:00:02.840686 12748 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T12:00:11.446146+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T10:00:00+00:00 TriggerDagRunOperator 2021-04-02T11:17:07.890021+00:00 2021-04-02T11:17:08.453716+00:00 0:00:00.563695 12741 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T11:17:05.536078+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T10:00:00+00:00 TriggerDagRunOperator 2021-04-02T11:17:07.820343+00:00 2021-04-02T11:17:08.242677+00:00 0:00:00.422334 12740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T11:17:05.536046+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T10:00:00+00:00 EmrJobFlowSensor 2021-04-02T11:06:53.017134+00:00 2021-04-02T11:16:55.738134+00:00 0:10:02.721000 12738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T11:06:50.661705+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T11:06:31.251215+00:00 2021-04-02T11:06:32.953802+00:00 0:00:01.702587 12736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T11:06:28.660441+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T10:00:00+00:00 PythonOperator 2021-04-02T11:06:08.986307+00:00 2021-04-02T11:06:11.827470+00:00 0:00:02.841163 12734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T11:06:06.509926+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T09:00:00+00:00 TriggerDagRunOperator 2021-04-02T10:10:02.365595+00:00 2021-04-02T10:10:02.917735+00:00 0:00:00.552140 12726 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T10:09:59.757512+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T09:00:00+00:00 TriggerDagRunOperator 2021-04-02T10:10:02.282973+00:00 2021-04-02T10:10:02.733031+00:00 0:00:00.450058 12725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T10:09:59.757470+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T09:00:00+00:00 EmrJobFlowSensor 2021-04-02T10:00:49.337984+00:00 2021-04-02T10:09:52.133984+00:00 0:09:02.796000 12721 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T10:00:46.950777+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T10:00:29.247624+00:00 2021-04-02T10:00:31.051850+00:00 0:00:01.804226 12720 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T10:00:26.848665+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T09:00:00+00:00 PythonOperator 2021-04-02T10:00:07.096809+00:00 2021-04-02T10:00:09.800667+00:00 0:00:02.703858 12719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T10:00:04.831944+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T08:00:00+00:00 TriggerDagRunOperator 2021-04-02T09:11:07.099283+00:00 2021-04-02T09:11:07.550423+00:00 0:00:00.451140 12711 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T09:11:04.663719+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T08:00:00+00:00 TriggerDagRunOperator 2021-04-02T09:11:07.109499+00:00 2021-04-02T09:11:07.682388+00:00 0:00:00.572889 12710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T09:11:04.663687+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T08:00:00+00:00 EmrJobFlowSensor 2021-04-02T09:00:53.625739+00:00 2021-04-02T09:10:56.391087+00:00 0:10:02.765348 12706 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T09:00:51.419677+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T09:00:31.802460+00:00 2021-04-02T09:00:33.507334+00:00 0:00:01.704874 12705 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T09:00:29.459286+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T08:00:00+00:00 PythonOperator 2021-04-02T09:00:11.652756+00:00 2021-04-02T09:00:14.382514+00:00 0:00:02.729758 12704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T09:00:09.384512+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T07:00:00+00:00 TriggerDagRunOperator 2021-04-02T08:10:16.329769+00:00 2021-04-02T08:10:16.843850+00:00 0:00:00.514081 12696 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T08:10:13.997629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T07:00:00+00:00 TriggerDagRunOperator 2021-04-02T08:10:16.193497+00:00 2021-04-02T08:10:16.618600+00:00 0:00:00.425103 12695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T08:10:13.997580+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T07:00:00+00:00 EmrJobFlowSensor 2021-04-02T08:00:55.023635+00:00 2021-04-02T08:09:57.742465+00:00 0:09:02.718830 12691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T08:00:52.657401+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T08:00:32.845899+00:00 2021-04-02T08:00:34.641999+00:00 0:00:01.796100 12690 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T08:00:30.580484+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T07:00:00+00:00 PythonOperator 2021-04-02T08:00:12.970410+00:00 2021-04-02T08:00:15.795428+00:00 0:00:02.825018 12689 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T08:00:10.563007+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T06:00:00+00:00 TriggerDagRunOperator 2021-04-02T07:11:35.389598+00:00 2021-04-02T07:11:35.953481+00:00 0:00:00.563883 12681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T07:11:32.948162+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T06:00:00+00:00 TriggerDagRunOperator 2021-04-02T07:11:35.201457+00:00 2021-04-02T07:11:35.663377+00:00 0:00:00.461920 12680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T07:11:32.948196+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T06:00:00+00:00 EmrJobFlowSensor 2021-04-02T07:01:12.400048+00:00 2021-04-02T07:11:15.248339+00:00 0:10:02.848291 12676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T07:01:10.046970+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T07:00:50.233517+00:00 2021-04-02T07:00:52.014626+00:00 0:00:01.781109 12675 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T07:00:47.948158+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T06:00:00+00:00 PythonOperator 2021-04-02T07:00:24.607429+00:00 2021-04-02T07:00:27.347663+00:00 0:00:02.740234 12674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T07:00:21.925973+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T05:00:00+00:00 TriggerDagRunOperator 2021-04-02T06:11:27.674338+00:00 2021-04-02T06:11:28.202674+00:00 0:00:00.528336 12666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T06:11:24.967265+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T05:00:00+00:00 TriggerDagRunOperator 2021-04-02T06:11:27.575904+00:00 2021-04-02T06:11:28.029259+00:00 0:00:00.453355 12665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T06:11:24.967230+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T05:00:00+00:00 EmrJobFlowSensor 2021-04-02T06:01:16.545925+00:00 2021-04-02T06:11:19.521918+00:00 0:10:02.975993 12661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T06:01:14.144125+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T06:00:56.461459+00:00 2021-04-02T06:00:58.209375+00:00 0:00:01.747916 12660 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T06:00:54.161486+00:00 2 default_pool