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-03-20T22:00:00+00:00 PythonOperator 2021-03-20T23:00:14.497658+00:00 2021-03-20T23:00:17.275979+00:00 0:00:02.778321 10168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T23:00:11.926753+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T21:00:00+00:00 TriggerDagRunOperator 2021-03-20T22:11:04.992334+00:00 2021-03-20T22:11:05.576368+00:00 0:00:00.584034 10163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T22:11:02.435529+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T21:00:00+00:00 TriggerDagRunOperator 2021-03-20T22:11:04.701111+00:00 2021-03-20T22:11:05.088467+00:00 0:00:00.387356 10162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T22:11:02.435564+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T21:00:00+00:00 EmrJobFlowSensor 2021-03-20T22:00:47.659970+00:00 2021-03-20T22:10:50.346937+00:00 0:10:02.686967 10161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T22:00:45.424476+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T22:00:31.427831+00:00 2021-03-20T22:00:33.131006+00:00 0:00:01.703175 10160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T22:00:29.294535+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T21:00:00+00:00 PythonOperator 2021-03-20T22:00:15.979813+00:00 2021-03-20T22:00:18.929047+00:00 0:00:02.949234 10159 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T22:00:13.283341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T20:00:00+00:00 TriggerDagRunOperator 2021-03-20T21:11:04.198028+00:00 2021-03-20T21:11:04.771175+00:00 0:00:00.573147 10154 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T21:11:01.898946+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T20:00:00+00:00 TriggerDagRunOperator 2021-03-20T21:11:04.099626+00:00 2021-03-20T21:11:04.541970+00:00 0:00:00.442344 10153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T21:11:01.898919+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T20:00:00+00:00 EmrJobFlowSensor 2021-03-20T21:00:41.000401+00:00 2021-03-20T21:10:43.763406+00:00 0:10:02.763005 10152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T21:00:38.770835+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T21:00:25.134753+00:00 2021-03-20T21:00:26.960094+00:00 0:00:01.825341 10151 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T21:00:22.759740+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T20:00:00+00:00 PythonOperator 2021-03-20T21:00:09.531791+00:00 2021-03-20T21:00:12.242616+00:00 0:00:02.710825 10150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T21:00:06.670065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T19:00:00+00:00 TriggerDagRunOperator 2021-03-20T20:10:54.605674+00:00 2021-03-20T20:10:55.135608+00:00 0:00:00.529934 10145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T20:10:52.029159+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T19:00:00+00:00 TriggerDagRunOperator 2021-03-20T20:10:54.533087+00:00 2021-03-20T20:10:54.915261+00:00 0:00:00.382174 10144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T20:10:52.029116+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T19:00:00+00:00 EmrJobFlowSensor 2021-03-20T20:01:23.083253+00:00 2021-03-20T20:10:25.748625+00:00 0:09:02.665372 10143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T20:01:20.885359+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T20:00:55.340133+00:00 2021-03-20T20:00:57.240236+00:00 0:00:01.900103 10142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T20:00:52.863718+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T19:00:00+00:00 PythonOperator 2021-03-20T20:00:39.690820+00:00 2021-03-20T20:00:42.395031+00:00 0:00:02.704211 10141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T20:00:36.731851+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T18:00:00+00:00 TriggerDagRunOperator 2021-03-20T19:11:06.389865+00:00 2021-03-20T19:11:06.809239+00:00 0:00:00.419374 10136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T19:11:03.966095+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T18:00:00+00:00 TriggerDagRunOperator 2021-03-20T19:11:06.331920+00:00 2021-03-20T19:11:06.936049+00:00 0:00:00.604129 10135 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T19:11:03.966068+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T18:00:00+00:00 EmrJobFlowSensor 2021-03-20T19:00:51.250520+00:00 2021-03-20T19:10:54.084865+00:00 0:10:02.834345 10134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T19:00:49.024301+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T19:00:35.104092+00:00 2021-03-20T19:00:36.799315+00:00 0:00:01.695223 10133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T19:00:32.945061+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T18:00:00+00:00 PythonOperator 2021-03-20T19:00:19.617436+00:00 2021-03-20T19:00:22.520607+00:00 0:00:02.903171 10132 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T19:00:16.887320+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T17:00:00+00:00 TriggerDagRunOperator 2021-03-20T18:10:14.071738+00:00 2021-03-20T18:10:14.598521+00:00 0:00:00.526783 10127 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T18:10:11.607297+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T17:00:00+00:00 TriggerDagRunOperator 2021-03-20T18:10:13.846051+00:00 2021-03-20T18:10:14.301251+00:00 0:00:00.455200 10126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T18:10:11.607324+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T17:00:00+00:00 EmrJobFlowSensor 2021-03-20T18:00:52.705147+00:00 2021-03-20T18:09:55.248080+00:00 0:09:02.542933 10125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T18:00:50.465901+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T18:00:36.509949+00:00 2021-03-20T18:00:38.238977+00:00 0:00:01.729028 10124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T18:00:34.349237+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T17:00:00+00:00 PythonOperator 2021-03-20T18:00:08.894113+00:00 2021-03-20T18:00:11.608636+00:00 0:00:02.714523 10123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T18:00:06.290054+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T16:00:00+00:00 TriggerDagRunOperator 2021-03-20T17:10:45.767822+00:00 2021-03-20T17:10:46.285000+00:00 0:00:00.517178 10118 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T17:10:42.987730+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T16:00:00+00:00 TriggerDagRunOperator 2021-03-20T17:10:45.225689+00:00 2021-03-20T17:10:45.614192+00:00 0:00:00.388503 10117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T17:10:42.987759+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T16:00:00+00:00 EmrJobFlowSensor 2021-03-20T17:00:36.324661+00:00 2021-03-20T17:10:39.285476+00:00 0:10:02.960815 10116 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T17:00:33.865093+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T17:00:20.111437+00:00 2021-03-20T17:00:21.848896+00:00 0:00:01.737459 10115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T17:00:17.859028+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T16:00:00+00:00 PythonOperator 2021-03-20T17:00:04.804304+00:00 2021-03-20T17:00:07.674848+00:00 0:00:02.870544 10114 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T17:00:01.793220+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T15:00:00+00:00 TriggerDagRunOperator 2021-03-20T16:11:10.830544+00:00 2021-03-20T16:11:11.357316+00:00 0:00:00.526772 10109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T16:11:08.486236+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T15:00:00+00:00 TriggerDagRunOperator 2021-03-20T16:11:10.704517+00:00 2021-03-20T16:11:11.119510+00:00 0:00:00.414993 10108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T16:11:08.486268+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T15:00:00+00:00 EmrJobFlowSensor 2021-03-20T16:01:00.230691+00:00 2021-03-20T16:11:03.338124+00:00 0:10:03.107433 10107 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T16:00:57.527869+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T16:00:41.540358+00:00 2021-03-20T16:00:43.226897+00:00 0:00:01.686539 10106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T16:00:39.393359+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T15:00:00+00:00 PythonOperator 2021-03-20T16:00:15.688316+00:00 2021-03-20T16:00:18.376638+00:00 0:00:02.688322 10105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T16:00:13.370412+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T14:00:00+00:00 TriggerDagRunOperator 2021-03-20T15:10:58.923353+00:00 2021-03-20T15:10:59.507164+00:00 0:00:00.583811 10100 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T15:10:56.496608+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T14:00:00+00:00 TriggerDagRunOperator 2021-03-20T15:10:58.827283+00:00 2021-03-20T15:10:59.217254+00:00 0:00:00.389971 10099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T15:10:56.496566+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T14:00:00+00:00 EmrJobFlowSensor 2021-03-20T15:00:51.620790+00:00 2021-03-20T15:10:54.358695+00:00 0:10:02.737905 10098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T15:00:49.417436+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T15:00:27.675471+00:00 2021-03-20T15:00:29.402537+00:00 0:00:01.727066 10097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T15:00:25.378855+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T14:00:00+00:00 PythonOperator 2021-03-20T15:00:11.779021+00:00 2021-03-20T15:00:14.676893+00:00 0:00:02.897872 10096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T15:00:09.426506+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T13:00:00+00:00 TriggerDagRunOperator 2021-03-20T14:29:44.988551+00:00 2021-03-20T14:29:45.652276+00:00 0:00:00.663725 10092 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T14:29:42.425645+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T13:00:00+00:00 TriggerDagRunOperator 2021-03-20T14:29:44.935211+00:00 2021-03-20T14:29:45.378208+00:00 0:00:00.442997 10091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T14:29:42.425600+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T13:00:00+00:00 EmrJobFlowSensor 2021-03-20T14:19:15.594564+00:00 2021-03-20T14:29:18.479387+00:00 0:10:02.884823 10090 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T14:19:13.263028+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T14:18:59.479106+00:00 2021-03-20T14:19:01.155735+00:00 0:00:01.676629 10089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T14:18:57.227782+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T13:00:00+00:00 PythonOperator 2021-03-20T14:18:41.560710+00:00 2021-03-20T14:18:44.487547+00:00 0:00:02.926837 10088 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T14:18:39.176633+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T12:00:00+00:00 TriggerDagRunOperator 2021-03-20T13:09:58.254196+00:00 2021-03-20T13:09:58.798834+00:00 0:00:00.544638 10083 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T13:09:55.780580+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T12:00:00+00:00 TriggerDagRunOperator 2021-03-20T13:09:58.073381+00:00 2021-03-20T13:09:58.487896+00:00 0:00:00.414515 10082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T13:09:55.780607+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T12:00:00+00:00 EmrJobFlowSensor 2021-03-20T13:00:39.472145+00:00 2021-03-20T13:09:42.091476+00:00 0:09:02.619331 10081 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T13:00:36.923676+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T13:00:23.083365+00:00 2021-03-20T13:00:24.885343+00:00 0:00:01.801978 10080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T13:00:20.795059+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T12:00:00+00:00 PythonOperator 2021-03-20T13:00:06.997248+00:00 2021-03-20T13:00:09.690290+00:00 0:00:02.693042 10079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T13:00:04.781034+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T11:00:00+00:00 TriggerDagRunOperator 2021-03-20T12:11:55.265151+00:00 2021-03-20T12:11:55.763918+00:00 0:00:00.498767 10074 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T12:11:52.560522+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T11:00:00+00:00 TriggerDagRunOperator 2021-03-20T12:11:54.707623+00:00 2021-03-20T12:11:55.098401+00:00 0:00:00.390778 10073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T12:11:52.560489+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T11:00:00+00:00 EmrJobFlowSensor 2021-03-20T12:00:43.730470+00:00 2021-03-20T12:11:46.832066+00:00 0:11:03.101596 10072 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T12:00:41.290751+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T12:00:27.413322+00:00 2021-03-20T12:00:29.122905+00:00 0:00:01.709583 10071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T12:00:25.276622+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T11:00:00+00:00 PythonOperator 2021-03-20T12:00:10.135647+00:00 2021-03-20T12:00:12.880594+00:00 0:00:02.744947 10070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T12:00:07.323207+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T10:00:00+00:00 TriggerDagRunOperator 2021-03-20T11:10:12.688534+00:00 2021-03-20T11:10:13.226666+00:00 0:00:00.538132 10065 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T11:10:10.129457+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T10:00:00+00:00 TriggerDagRunOperator 2021-03-20T11:10:12.608688+00:00 2021-03-20T11:10:13.012141+00:00 0:00:00.403453 10064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T11:10:10.129496+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T10:00:00+00:00 EmrJobFlowSensor 2021-03-20T11:01:01.462412+00:00 2021-03-20T11:10:04.092525+00:00 0:09:02.630113 10063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T11:00:59.245329+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T11:00:33.385019+00:00 2021-03-20T11:00:35.141959+00:00 0:00:01.756940 10062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T11:00:31.220209+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T10:00:00+00:00 PythonOperator 2021-03-20T11:00:18.034205+00:00 2021-03-20T11:00:20.862462+00:00 0:00:02.828257 10061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T11:00:15.173587+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T09:00:00+00:00 TriggerDagRunOperator 2021-03-20T10:10:08.157089+00:00 2021-03-20T10:10:08.884006+00:00 0:00:00.726917 10056 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T10:10:05.770045+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T09:00:00+00:00 TriggerDagRunOperator 2021-03-20T10:10:07.985064+00:00 2021-03-20T10:10:08.408265+00:00 0:00:00.423201 10055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T10:10:05.770016+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T09:00:00+00:00 EmrJobFlowSensor 2021-03-20T10:00:55.333104+00:00 2021-03-20T10:09:58.108018+00:00 0:09:02.774914 10054 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T10:00:52.980007+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T10:00:35.301294+00:00 2021-03-20T10:00:36.996040+00:00 0:00:01.694746 10053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T10:00:32.967047+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T09:00:00+00:00 PythonOperator 2021-03-20T10:00:15.395307+00:00 2021-03-20T10:00:18.163249+00:00 0:00:02.767942 10052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T10:00:12.929411+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T08:00:00+00:00 TriggerDagRunOperator 2021-03-20T09:11:17.857871+00:00 2021-03-20T09:11:18.406423+00:00 0:00:00.548552 10047 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T09:11:15.534856+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T08:00:00+00:00 TriggerDagRunOperator 2021-03-20T09:11:17.778033+00:00 2021-03-20T09:11:18.162341+00:00 0:00:00.384308 10046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T09:11:15.534886+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T08:00:00+00:00 EmrJobFlowSensor 2021-03-20T09:00:51.146071+00:00 2021-03-20T09:10:53.973837+00:00 0:10:02.827766 10045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T09:00:48.329246+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T09:00:34.324771+00:00 2021-03-20T09:00:35.988298+00:00 0:00:01.663527 10044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T09:00:32.163120+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T08:00:00+00:00 PythonOperator 2021-03-20T09:00:18.857439+00:00 2021-03-20T09:00:21.924893+00:00 0:00:03.067454 10043 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T09:00:16.082887+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T07:00:00+00:00 TriggerDagRunOperator 2021-03-20T08:10:04.794662+00:00 2021-03-20T08:10:05.180322+00:00 0:00:00.385660 10038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T08:10:02.365733+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T07:00:00+00:00 TriggerDagRunOperator 2021-03-20T08:10:04.773272+00:00 2021-03-20T08:10:05.320426+00:00 0:00:00.547154 10037 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T08:10:02.365773+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T07:00:00+00:00 EmrJobFlowSensor 2021-03-20T08:00:47.685503+00:00 2021-03-20T08:09:50.367007+00:00 0:09:02.681504 10036 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T08:00:45.377152+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T08:00:29.641099+00:00 2021-03-20T08:00:31.328039+00:00 0:00:01.686940 10035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T08:00:27.425942+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T07:00:00+00:00 PythonOperator 2021-03-20T08:00:13.525207+00:00 2021-03-20T08:00:16.226650+00:00 0:00:02.701443 10034 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T08:00:11.294149+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T06:00:00+00:00 TriggerDagRunOperator 2021-03-20T07:11:11.249985+00:00 2021-03-20T07:11:11.777387+00:00 0:00:00.527402 10026 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T07:11:08.907046+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T06:00:00+00:00 TriggerDagRunOperator 2021-03-20T07:11:11.187096+00:00 2021-03-20T07:11:11.635850+00:00 0:00:00.448754 10025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T07:11:08.907079+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T06:00:00+00:00 EmrJobFlowSensor 2021-03-20T07:01:00.034892+00:00 2021-03-20T07:11:02.903658+00:00 0:10:02.868766 10024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T07:00:57.815485+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T07:00:33.863688+00:00 2021-03-20T07:00:35.600380+00:00 0:00:01.736692 10023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T07:00:31.694788+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T06:00:00+00:00 PythonOperator 2021-03-20T07:00:08.280885+00:00 2021-03-20T07:00:10.990106+00:00 0:00:02.709221 10022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T07:00:05.672426+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T05:00:00+00:00 TriggerDagRunOperator 2021-03-20T06:10:22.054666+00:00 2021-03-20T06:10:22.592172+00:00 0:00:00.537506 10017 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T06:10:19.044197+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T05:00:00+00:00 TriggerDagRunOperator 2021-03-20T06:10:21.524098+00:00 2021-03-20T06:10:21.896948+00:00 0:00:00.372850 10016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T06:10:19.044228+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T05:00:00+00:00 EmrJobFlowSensor 2021-03-20T06:01:12.177189+00:00 2021-03-20T06:10:14.979915+00:00 0:09:02.802726 10015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T06:01:09.873407+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T06:00:48.052422+00:00 2021-03-20T06:00:49.778306+00:00 0:00:01.725884 10014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T06:00:45.859500+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T05:00:00+00:00 PythonOperator 2021-03-20T06:00:30.522006+00:00 2021-03-20T06:00:33.416366+00:00 0:00:02.894360 10013 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T06:00:27.814943+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T04:00:00+00:00 TriggerDagRunOperator 2021-03-20T05:11:49.359506+00:00 2021-03-20T05:11:49.895809+00:00 0:00:00.536303 10008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T05:11:46.668483+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T04:00:00+00:00 TriggerDagRunOperator 2021-03-20T05:11:49.229876+00:00 2021-03-20T05:11:49.656419+00:00 0:00:00.426543 10007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T05:11:46.668449+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T04:00:00+00:00 EmrJobFlowSensor 2021-03-20T05:01:39.438139+00:00 2021-03-20T05:11:42.239734+00:00 0:10:02.801595 10006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T05:01:37.237132+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T05:01:23.839626+00:00 2021-03-20T05:01:25.819521+00:00 0:00:01.979895 10005 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T05:01:21.213657+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T04:00:00+00:00 PythonOperator 2021-03-20T05:00:17.434032+00:00 2021-03-20T05:00:20.176562+00:00 0:00:02.742530 10004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T05:00:15.085167+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T03:00:00+00:00 TriggerDagRunOperator 2021-03-20T04:11:10.706944+00:00 2021-03-20T04:11:11.237030+00:00 0:00:00.530086 9999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T04:11:08.369735+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T03:00:00+00:00 TriggerDagRunOperator 2021-03-20T04:11:10.619411+00:00 2021-03-20T04:11:11.006359+00:00 0:00:00.386948 9998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T04:11:08.369708+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T03:00:00+00:00 EmrJobFlowSensor 2021-03-20T04:00:49.677448+00:00 2021-03-20T04:10:52.351153+00:00 0:10:02.673705 9997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T04:00:47.442119+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T04:00:33.879616+00:00 2021-03-20T04:00:35.776836+00:00 0:00:01.897220 9996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T04:00:31.375581+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T03:00:00+00:00 PythonOperator 2021-03-20T04:00:17.719133+00:00 2021-03-20T04:00:20.473861+00:00 0:00:02.754728 9995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T04:00:15.426590+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T02:00:00+00:00 TriggerDagRunOperator 2021-03-20T03:15:24.796079+00:00 2021-03-20T03:15:25.336460+00:00 0:00:00.540381 9991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T03:15:22.203581+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T02:00:00+00:00 TriggerDagRunOperator 2021-03-20T03:15:24.735724+00:00 2021-03-20T03:15:25.156896+00:00 0:00:00.421172 9990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T03:15:22.203609+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T02:00:00+00:00 EmrJobFlowSensor 2021-03-20T03:01:10.173299+00:00 2021-03-20T03:11:13.165188+00:00 0:10:02.991889 9988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T03:01:07.694205+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T03:00:48.077099+00:00 2021-03-20T03:00:49.935454+00:00 0:00:01.858355 9987 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T03:00:45.676745+00:00 2 default_pool