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-04T17:00:00+00:00 PythonOperator 2021-04-04T18:00:10.613335+00:00 2021-04-04T18:00:13.325253+00:00 0:00:02.711918 13559 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T18:00:08.316108+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T16:00:00+00:00 TriggerDagRunOperator 2021-04-04T17:10:08.384634+00:00 2021-04-04T17:10:08.910488+00:00 0:00:00.525854 13551 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T17:10:05.951725+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T16:00:00+00:00 TriggerDagRunOperator 2021-04-04T17:10:08.245661+00:00 2021-04-04T17:10:08.739880+00:00 0:00:00.494219 13550 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T17:10:05.951755+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T16:00:00+00:00 EmrJobFlowSensor 2021-04-04T17:00:51.326457+00:00 2021-04-04T17:09:53.938187+00:00 0:09:02.611730 13546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T17:00:49.064067+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T17:00:29.342375+00:00 2021-04-04T17:00:31.140148+00:00 0:00:01.797773 13545 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T17:00:27.036674+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T16:00:00+00:00 PythonOperator 2021-04-04T17:00:09.409456+00:00 2021-04-04T17:00:12.305468+00:00 0:00:02.896012 13544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T17:00:07.018664+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T15:00:00+00:00 TriggerDagRunOperator 2021-04-04T16:11:41.809106+00:00 2021-04-04T16:11:42.219795+00:00 0:00:00.410689 13536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T16:11:39.598597+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T15:00:00+00:00 TriggerDagRunOperator 2021-04-04T16:11:41.824954+00:00 2021-04-04T16:11:42.349894+00:00 0:00:00.524940 13535 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T16:11:39.598560+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T15:00:00+00:00 EmrJobFlowSensor 2021-04-04T16:01:02.971558+00:00 2021-04-04T16:11:05.726672+00:00 0:10:02.755114 13531 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T16:01:00.583351+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T16:00:40.728682+00:00 2021-04-04T16:00:42.422535+00:00 0:00:01.693853 13530 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T16:00:38.535035+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T15:00:00+00:00 PythonOperator 2021-04-04T16:00:20.749339+00:00 2021-04-04T16:00:23.658962+00:00 0:00:02.909623 13529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T16:00:18.508228+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T14:00:00+00:00 TriggerDagRunOperator 2021-04-04T15:21:53.513788+00:00 2021-04-04T15:21:54.180229+00:00 0:00:00.666441 13522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T15:21:50.900933+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T14:00:00+00:00 TriggerDagRunOperator 2021-04-04T15:21:53.430119+00:00 2021-04-04T15:21:54.140734+00:00 0:00:00.710615 13521 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T15:21:50.900905+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T14:00:00+00:00 EmrJobFlowSensor 2021-04-04T15:01:04.541569+00:00 2021-04-04T15:11:07.490955+00:00 0:10:02.949386 13516 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T15:01:02.208560+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T15:00:42.478029+00:00 2021-04-04T15:00:44.181195+00:00 0:00:01.703166 13515 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T15:00:40.189909+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T14:00:00+00:00 PythonOperator 2021-04-04T15:00:22.329881+00:00 2021-04-04T15:00:25.096195+00:00 0:00:02.766314 13514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T15:00:20.160782+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T13:00:00+00:00 TriggerDagRunOperator 2021-04-04T14:09:03.950092+00:00 2021-04-04T14:09:04.374602+00:00 0:00:00.424510 13507 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T14:09:01.246538+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T13:00:00+00:00 TriggerDagRunOperator 2021-04-04T14:09:03.594856+00:00 2021-04-04T14:09:04.173886+00:00 0:00:00.579030 13506 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T14:09:01.246510+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T13:00:00+00:00 EmrJobFlowSensor 2021-04-04T14:00:48.685463+00:00 2021-04-04T14:08:51.177681+00:00 0:08:02.492218 13501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T14:00:46.426055+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T14:00:28.620007+00:00 2021-04-04T14:00:30.322511+00:00 0:00:01.702504 13500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T14:00:26.408728+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T13:00:00+00:00 PythonOperator 2021-04-04T14:00:06.746468+00:00 2021-04-04T14:00:09.562983+00:00 0:00:02.816515 13499 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T14:00:04.388665+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T12:00:00+00:00 TriggerDagRunOperator 2021-04-04T13:11:14.233283+00:00 2021-04-04T13:11:14.682388+00:00 0:00:00.449105 13492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T13:11:11.607877+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T12:00:00+00:00 TriggerDagRunOperator 2021-04-04T13:11:14.085451+00:00 2021-04-04T13:11:14.667636+00:00 0:00:00.582185 13491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T13:11:11.607913+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T12:00:00+00:00 EmrJobFlowSensor 2021-04-04T13:01:04.038764+00:00 2021-04-04T13:11:06.764465+00:00 0:10:02.725701 13486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T13:01:01.745364+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T13:00:41.911778+00:00 2021-04-04T13:00:43.598166+00:00 0:00:01.686388 13485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T13:00:39.693465+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T12:00:00+00:00 PythonOperator 2021-04-04T13:00:05.964176+00:00 2021-04-04T13:00:08.682362+00:00 0:00:02.718186 13484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T13:00:03.626304+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T11:00:00+00:00 TriggerDagRunOperator 2021-04-04T12:10:06.977972+00:00 2021-04-04T12:10:07.493044+00:00 0:00:00.515072 13477 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:10:04.586258+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T11:00:00+00:00 TriggerDagRunOperator 2021-04-04T12:10:06.789475+00:00 2021-04-04T12:10:07.196340+00:00 0:00:00.406865 13476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:10:04.586225+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T11:00:00+00:00 EmrJobFlowSensor 2021-04-04T12:00:49.909403+00:00 2021-04-04T12:09:52.635361+00:00 0:09:02.725958 13471 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T12:00:47.622693+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T12:00:26.307259+00:00 2021-04-04T12:00:27.979414+00:00 0:00:01.672155 13470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T12:00:23.680826+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T11:00:00+00:00 PythonOperator 2021-04-04T12:00:06.108440+00:00 2021-04-04T12:00:08.849909+00:00 0:00:02.741469 13469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T12:00:03.662635+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T10:00:00+00:00 TriggerDagRunOperator 2021-04-04T11:11:27.215319+00:00 2021-04-04T11:11:27.658391+00:00 0:00:00.443072 13462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T11:11:24.816825+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T10:00:00+00:00 TriggerDagRunOperator 2021-04-04T11:11:27.125637+00:00 2021-04-04T11:11:27.683226+00:00 0:00:00.557589 13461 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T11:11:24.816853+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T10:00:00+00:00 EmrJobFlowSensor 2021-04-04T11:02:06.327398+00:00 2021-04-04T11:11:09.164528+00:00 0:09:02.837130 13457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T11:02:03.957082+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T11:01:44.026062+00:00 2021-04-04T11:01:45.739923+00:00 0:00:01.713861 13456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T11:01:41.857902+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T10:00:00+00:00 PythonOperator 2021-04-04T11:01:12.615693+00:00 2021-04-04T11:01:15.457791+00:00 0:00:02.842098 13455 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T11:01:09.874778+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T09:00:00+00:00 TriggerDagRunOperator 2021-04-04T10:10:26.087166+00:00 2021-04-04T10:10:26.538761+00:00 0:00:00.451595 13447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T10:10:23.685384+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T09:00:00+00:00 TriggerDagRunOperator 2021-04-04T10:10:25.998394+00:00 2021-04-04T10:10:26.585282+00:00 0:00:00.586888 13446 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T10:10:23.685419+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T09:00:00+00:00 EmrJobFlowSensor 2021-04-04T10:01:14.847876+00:00 2021-04-04T10:10:17.620397+00:00 0:09:02.772521 13442 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T10:01:12.508789+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T10:00:54.799794+00:00 2021-04-04T10:00:56.581350+00:00 0:00:01.781556 13441 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T10:00:52.449908+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T09:00:00+00:00 PythonOperator 2021-04-04T10:00:22.815828+00:00 2021-04-04T10:00:25.590785+00:00 0:00:02.774957 13440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T10:00:20.421534+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T08:00:00+00:00 TriggerDagRunOperator 2021-04-04T09:09:59.537739+00:00 2021-04-04T09:10:00.156549+00:00 0:00:00.618810 13432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T09:09:56.972171+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T08:00:00+00:00 TriggerDagRunOperator 2021-04-04T09:09:59.233914+00:00 2021-04-04T09:09:59.703864+00:00 0:00:00.469950 13431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T09:09:56.972206+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T08:00:00+00:00 EmrJobFlowSensor 2021-04-04T09:00:50.302082+00:00 2021-04-04T09:09:53.002715+00:00 0:09:02.700633 13427 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T09:00:48.098629+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T09:00:30.551481+00:00 2021-04-04T09:00:32.366464+00:00 0:00:01.814983 13426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T09:00:28.162253+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T08:00:00+00:00 PythonOperator 2021-04-04T09:00:08.720953+00:00 2021-04-04T09:00:11.554998+00:00 0:00:02.834045 13425 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T09:00:06.063625+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T07:00:00+00:00 TriggerDagRunOperator 2021-04-04T08:11:58.551752+00:00 2021-04-04T08:11:59.081946+00:00 0:00:00.530194 13417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T08:11:55.952871+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T07:00:00+00:00 TriggerDagRunOperator 2021-04-04T08:11:58.402615+00:00 2021-04-04T08:11:58.840140+00:00 0:00:00.437525 13416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T08:11:55.952923+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T07:00:00+00:00 EmrJobFlowSensor 2021-04-04T08:01:19.171818+00:00 2021-04-04T08:11:22.025393+00:00 0:10:02.853575 13412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T08:01:16.871976+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T08:00:45.417665+00:00 2021-04-04T08:00:47.143018+00:00 0:00:01.725353 13411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T08:00:42.824345+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T07:00:00+00:00 PythonOperator 2021-04-04T08:00:23.119192+00:00 2021-04-04T08:00:25.969827+00:00 0:00:02.850635 13410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T08:00:20.807923+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T06:00:00+00:00 TriggerDagRunOperator 2021-04-04T07:11:29.693685+00:00 2021-04-04T07:11:30.234429+00:00 0:00:00.540744 13402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T07:11:27.189891+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T06:00:00+00:00 TriggerDagRunOperator 2021-04-04T07:11:29.573303+00:00 2021-04-04T07:11:29.978133+00:00 0:00:00.404830 13401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T07:11:27.189853+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T06:00:00+00:00 EmrJobFlowSensor 2021-04-04T07:01:04.353311+00:00 2021-04-04T07:11:07.196185+00:00 0:10:02.842874 13397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T07:01:01.866757+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T07:00:42.144008+00:00 2021-04-04T07:00:43.997189+00:00 0:00:01.853181 13396 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T07:00:39.850199+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T06:00:00+00:00 PythonOperator 2021-04-04T07:00:20.080810+00:00 2021-04-04T07:00:22.803712+00:00 0:00:02.722902 13395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T07:00:17.691064+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T05:00:00+00:00 TriggerDagRunOperator 2021-04-04T06:10:25.462073+00:00 2021-04-04T06:10:26.014591+00:00 0:00:00.552518 13387 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T06:10:23.006710+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T05:00:00+00:00 TriggerDagRunOperator 2021-04-04T06:10:25.349939+00:00 2021-04-04T06:10:25.815898+00:00 0:00:00.465959 13386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T06:10:23.006672+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T05:00:00+00:00 EmrJobFlowSensor 2021-04-04T06:01:04.668682+00:00 2021-04-04T06:10:07.438137+00:00 0:09:02.769455 13382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T06:01:02.055853+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T06:00:42.329187+00:00 2021-04-04T06:00:44.039118+00:00 0:00:01.709931 13381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T06:00:39.996827+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T05:00:00+00:00 PythonOperator 2021-04-04T06:00:20.303693+00:00 2021-04-04T06:00:23.016879+00:00 0:00:02.713186 13380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T06:00:17.969704+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T04:00:00+00:00 TriggerDagRunOperator 2021-04-04T05:11:30.872977+00:00 2021-04-04T05:11:31.383188+00:00 0:00:00.510211 13372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T05:11:28.241121+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T04:00:00+00:00 TriggerDagRunOperator 2021-04-04T05:11:30.807664+00:00 2021-04-04T05:11:31.231563+00:00 0:00:00.423899 13371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T05:11:28.241064+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T04:00:00+00:00 EmrJobFlowSensor 2021-04-04T05:01:03.165430+00:00 2021-04-04T05:11:06.061450+00:00 0:10:02.896020 13367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T05:01:00.841327+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T05:00:43.073002+00:00 2021-04-04T05:00:44.923730+00:00 0:00:01.850728 13366 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T05:00:40.823300+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T04:00:00+00:00 PythonOperator 2021-04-04T05:00:21.146359+00:00 2021-04-04T05:00:24.037451+00:00 0:00:02.891092 13365 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T05:00:18.802072+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T03:00:00+00:00 TriggerDagRunOperator 2021-04-04T04:11:42.931230+00:00 2021-04-04T04:11:43.340714+00:00 0:00:00.409484 13357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T04:11:40.623316+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T03:00:00+00:00 TriggerDagRunOperator 2021-04-04T04:11:42.959065+00:00 2021-04-04T04:11:43.497781+00:00 0:00:00.538716 13356 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T04:11:40.623282+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T03:00:00+00:00 EmrJobFlowSensor 2021-04-04T04:01:17.908812+00:00 2021-04-04T04:11:20.619843+00:00 0:10:02.711031 13352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T04:01:15.775338+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T04:00:56.088043+00:00 2021-04-04T04:00:57.792283+00:00 0:00:01.704240 13351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T04:00:53.756544+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T03:00:00+00:00 PythonOperator 2021-04-04T04:00:26.331926+00:00 2021-04-04T04:00:29.035471+00:00 0:00:02.703545 13350 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T04:00:23.749637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T02:00:00+00:00 TriggerDagRunOperator 2021-04-04T03:10:19.403455+00:00 2021-04-04T03:10:19.930764+00:00 0:00:00.527309 13342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T03:10:16.389347+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T02:00:00+00:00 TriggerDagRunOperator 2021-04-04T03:10:18.752011+00:00 2021-04-04T03:10:19.145163+00:00 0:00:00.393152 13341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T03:10:16.389301+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T02:00:00+00:00 EmrJobFlowSensor 2021-04-04T03:01:03.812856+00:00 2021-04-04T03:10:06.654895+00:00 0:09:02.842039 13337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T03:01:01.185782+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T03:00:41.212827+00:00 2021-04-04T03:00:42.899247+00:00 0:00:01.686420 13336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T03:00:39.083173+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T02:00:00+00:00 PythonOperator 2021-04-04T03:00:21.352793+00:00 2021-04-04T03:00:24.107913+00:00 0:00:02.755120 13335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T03:00:19.064324+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T01:00:00+00:00 TriggerDagRunOperator 2021-04-04T02:11:00.035903+00:00 2021-04-04T02:11:00.569718+00:00 0:00:00.533815 13327 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T02:10:57.101454+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T01:00:00+00:00 TriggerDagRunOperator 2021-04-04T02:10:59.386851+00:00 2021-04-04T02:10:59.776462+00:00 0:00:00.389611 13326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T02:10:57.101489+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T01:00:00+00:00 EmrJobFlowSensor 2021-04-04T02:00:50.663076+00:00 2021-04-04T02:10:53.588493+00:00 0:10:02.925417 13322 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T02:00:48.157711+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T02:00:28.288037+00:00 2021-04-04T02:00:30.013492+00:00 0:00:01.725455 13321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T02:00:26.061341+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T01:00:00+00:00 PythonOperator 2021-04-04T02:00:08.429844+00:00 2021-04-04T02:00:11.224463+00:00 0:00:02.794619 13320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T02:00:06.044387+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T00:00:00+00:00 TriggerDagRunOperator 2021-04-04T01:11:37.866582+00:00 2021-04-04T01:11:38.474602+00:00 0:00:00.608020 13312 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T01:11:35.278439+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T00:00:00+00:00 TriggerDagRunOperator 2021-04-04T01:11:37.689484+00:00 2021-04-04T01:11:38.092538+00:00 0:00:00.403054 13311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T01:11:35.278390+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T00:00:00+00:00 EmrJobFlowSensor 2021-04-04T01:01:10.214990+00:00 2021-04-04T01:11:13.112473+00:00 0:10:02.897483 13307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T01:01:07.843602+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T01:00:48.150022+00:00 2021-04-04T01:00:49.834454+00:00 0:00:01.684432 13306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T01:00:45.821714+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T00:00:00+00:00 PythonOperator 2021-04-04T01:00:16.078641+00:00 2021-04-04T01:00:18.786758+00:00 0:00:02.708117 13305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T01:00:13.794797+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T23:00:00+00:00 TriggerDagRunOperator 2021-04-04T00:11:08.587733+00:00 2021-04-04T00:11:09.147866+00:00 0:00:00.560133 13297 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T00:11:06.231875+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T23:00:00+00:00 TriggerDagRunOperator 2021-04-04T00:11:08.552405+00:00 2021-04-04T00:11:09.007849+00:00 0:00:00.455444 13296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T00:11:06.231841+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T23:00:00+00:00 EmrJobFlowSensor 2021-04-04T00:00:51.666535+00:00 2021-04-04T00:10:54.650394+00:00 0:10:02.983859 13292 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T00:00:49.325077+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T00:00:32.023269+00:00 2021-04-04T00:00:33.738175+00:00 0:00:01.714906 13291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T00:00:29.468143+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T23:00:00+00:00 PythonOperator 2021-04-04T00:00:09.646081+00:00 2021-04-04T00:00:12.474727+00:00 0:00:02.828646 13290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T00:00:07.290141+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T22:00:00+00:00 TriggerDagRunOperator 2021-04-03T23:10:27.680621+00:00 2021-04-03T23:10:28.215389+00:00 0:00:00.534768 13280 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T23:10:25.396543+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T22:00:00+00:00 TriggerDagRunOperator 2021-04-03T23:10:27.645688+00:00 2021-04-03T23:10:28.064570+00:00 0:00:00.418882 13279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T23:10:25.396578+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T22:00:00+00:00 EmrJobFlowSensor 2021-04-03T23:01:02.855353+00:00 2021-04-03T23:10:05.564487+00:00 0:09:02.709134 13275 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T23:01:00.455921+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T23:00:40.605344+00:00 2021-04-03T23:00:42.302893+00:00 0:00:01.697549 13274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T23:00:38.344625+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T22:00:00+00:00 PythonOperator 2021-04-03T23:00:19.205981+00:00 2021-04-03T23:00:22.039622+00:00 0:00:02.833641 13273 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T23:00:16.372674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T21:00:00+00:00 TriggerDagRunOperator 2021-04-03T22:10:06.911508+00:00 2021-04-03T22:10:07.429894+00:00 0:00:00.518386 13265 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T22:10:04.501280+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T21:00:00+00:00 TriggerDagRunOperator 2021-04-03T22:10:06.764652+00:00 2021-04-03T22:10:07.170392+00:00 0:00:00.405740 13264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T22:10:04.501234+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T21:00:00+00:00 EmrJobFlowSensor 2021-04-03T22:00:49.825943+00:00 2021-04-03T22:09:52.586429+00:00 0:09:02.760486 13260 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T22:00:47.656276+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T22:00:28.097205+00:00 2021-04-03T22:00:29.938067+00:00 0:00:01.840862 13259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T22:00:25.637854+00:00 2 default_pool