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_cluster_and_add_emr_steps 2023-05-20T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T19:00:44.609552+00:00 2023-05-20T19:00:45.741450+00:00 0:00:01.131898 382853 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T19:00:42.006731+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T18:00:00+00:00 PythonOperator 2023-05-20T19:00:22.456955+00:00 2023-05-20T19:00:23.488253+00:00 0:00:01.031298 382852 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T19:00:19.946871+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T17:00:00+00:00 TriggerDagRunOperator 2023-05-20T18:11:06.088954+00:00 2023-05-20T18:11:06.589384+00:00 0:00:00.500430 382836 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T18:11:03.407631+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T17:00:00+00:00 TriggerDagRunOperator 2023-05-20T18:11:06.033883+00:00 2023-05-20T18:11:06.480261+00:00 0:00:00.446378 382835 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T18:11:03.407579+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T17:00:00+00:00 EmrJobFlowSensor 2023-05-20T18:00:49.163088+00:00 2023-05-20T18:10:51.124971+00:00 0:10:01.961883 382827 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T18:00:46.911558+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T18:00:27.159045+00:00 2023-05-20T18:00:28.096653+00:00 0:00:00.937608 382826 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T18:00:24.860973+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T17:00:00+00:00 PythonOperator 2023-05-20T18:00:07.770150+00:00 2023-05-20T18:00:08.908520+00:00 0:00:01.138370 382824 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T18:00:05.014357+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T16:00:00+00:00 TriggerDagRunOperator 2023-05-20T17:13:42.521773+00:00 2023-05-20T17:13:42.992577+00:00 0:00:00.470804 382811 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T17:13:40.104556+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T16:00:00+00:00 TriggerDagRunOperator 2023-05-20T17:13:42.506816+00:00 2023-05-20T17:13:43.014467+00:00 0:00:00.507651 382810 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T17:13:40.104586+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T16:00:00+00:00 EmrJobFlowSensor 2023-05-20T17:03:35.125295+00:00 2023-05-20T17:13:37.033339+00:00 0:10:01.908044 382803 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T17:03:32.828969+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T17:03:15.122719+00:00 2023-05-20T17:03:16.038741+00:00 0:00:00.916022 382801 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T17:03:12.808784+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T16:00:00+00:00 PythonOperator 2023-05-20T17:02:53.555023+00:00 2023-05-20T17:02:54.881952+00:00 0:00:01.326929 382799 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T17:02:50.791762+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T15:00:00+00:00 TriggerDagRunOperator 2023-05-20T16:12:29.213704+00:00 2023-05-20T16:12:29.671198+00:00 0:00:00.457494 382788 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T16:12:26.583256+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T15:00:00+00:00 TriggerDagRunOperator 2023-05-20T16:12:29.165544+00:00 2023-05-20T16:12:29.672336+00:00 0:00:00.506792 382787 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T16:12:26.583300+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T15:00:00+00:00 EmrJobFlowSensor 2023-05-20T16:02:03.637721+00:00 2023-05-20T16:12:05.605905+00:00 0:10:01.968184 382781 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T16:02:01.345230+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T16:01:41.543457+00:00 2023-05-20T16:01:42.553509+00:00 0:00:01.010052 382779 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T16:01:39.326472+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T15:00:00+00:00 PythonOperator 2023-05-20T16:01:21.531294+00:00 2023-05-20T16:01:22.627304+00:00 0:00:01.096010 382777 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T16:01:19.314013+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T14:00:00+00:00 TriggerDagRunOperator 2023-05-20T15:11:10.241450+00:00 2023-05-20T15:11:10.711651+00:00 0:00:00.470201 382764 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T15:11:07.939023+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T14:00:00+00:00 TriggerDagRunOperator 2023-05-20T15:11:10.194112+00:00 2023-05-20T15:11:10.665732+00:00 0:00:00.471620 382763 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T15:11:07.939059+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T14:00:00+00:00 EmrJobFlowSensor 2023-05-20T15:00:51.092469+00:00 2023-05-20T15:10:52.977061+00:00 0:10:01.884592 382756 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T15:00:48.753795+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T15:00:28.991140+00:00 2023-05-20T15:00:29.929064+00:00 0:00:00.937924 382754 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T15:00:26.737342+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T14:00:00+00:00 PythonOperator 2023-05-20T15:00:09.596219+00:00 2023-05-20T15:00:10.751333+00:00 0:00:01.155114 382752 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T15:00:06.789974+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T13:00:00+00:00 TriggerDagRunOperator 2023-05-20T14:25:06.065583+00:00 2023-05-20T14:25:06.556625+00:00 0:00:00.491042 382742 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T14:25:03.104221+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T13:00:00+00:00 TriggerDagRunOperator 2023-05-20T14:25:06.039172+00:00 2023-05-20T14:25:06.492231+00:00 0:00:00.453059 382741 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T14:25:03.104251+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T13:00:00+00:00 EmrJobFlowSensor 2023-05-20T14:01:04.579265+00:00 2023-05-20T14:11:06.852334+00:00 0:10:02.273069 382734 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T14:01:02.096418+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T14:00:42.287942+00:00 2023-05-20T14:00:43.275563+00:00 0:00:00.987621 382732 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T14:00:40.007464+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T13:00:00+00:00 PythonOperator 2023-05-20T14:00:20.942157+00:00 2023-05-20T14:00:22.058516+00:00 0:00:01.116359 382730 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T14:00:17.981223+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T12:00:00+00:00 TriggerDagRunOperator 2023-05-20T13:16:18.788029+00:00 2023-05-20T13:16:19.347561+00:00 0:00:00.559532 382719 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T13:16:15.910030+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T12:00:00+00:00 TriggerDagRunOperator 2023-05-20T13:16:18.384826+00:00 2023-05-20T13:16:18.832708+00:00 0:00:00.447882 382718 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T13:16:15.909998+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T12:00:00+00:00 EmrJobFlowSensor 2023-05-20T13:05:55.839431+00:00 2023-05-20T13:15:57.758794+00:00 0:10:01.919363 382713 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T13:05:53.547658+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T13:05:33.828088+00:00 2023-05-20T13:05:34.778208+00:00 0:00:00.950120 382710 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T13:05:31.529915+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T12:00:00+00:00 PythonOperator 2023-05-20T13:05:14.555313+00:00 2023-05-20T13:05:15.650163+00:00 0:00:01.094850 382707 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T13:05:11.513795+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T11:00:00+00:00 TriggerDagRunOperator 2023-05-20T12:11:30.465870+00:00 2023-05-20T12:11:30.967294+00:00 0:00:00.501424 382697 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T12:11:27.931093+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T11:00:00+00:00 TriggerDagRunOperator 2023-05-20T12:11:30.426773+00:00 2023-05-20T12:11:30.959535+00:00 0:00:00.532762 382696 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T12:11:27.931126+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T11:00:00+00:00 EmrJobFlowSensor 2023-05-20T12:01:12.029077+00:00 2023-05-20T12:11:13.922122+00:00 0:10:01.893045 382689 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T12:01:09.815890+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T12:00:50.018261+00:00 2023-05-20T12:00:50.985570+00:00 0:00:00.967309 382687 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T12:00:47.764586+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T11:00:00+00:00 PythonOperator 2023-05-20T12:00:30.722884+00:00 2023-05-20T12:00:31.709065+00:00 0:00:00.986181 382685 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T12:00:27.684316+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T10:00:00+00:00 TriggerDagRunOperator 2023-05-20T11:13:20.183655+00:00 2023-05-20T11:13:20.676897+00:00 0:00:00.493242 382673 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T11:13:17.558483+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T10:00:00+00:00 TriggerDagRunOperator 2023-05-20T11:13:20.173077+00:00 2023-05-20T11:13:20.635220+00:00 0:00:00.462143 382672 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T11:13:17.558512+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T10:00:00+00:00 EmrJobFlowSensor 2023-05-20T11:00:59.820580+00:00 2023-05-20T11:13:02.394474+00:00 0:12:02.573894 382664 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T11:00:57.393280+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T11:00:37.939344+00:00 2023-05-20T11:00:39.177285+00:00 0:00:01.237941 382662 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T11:00:35.380877+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T10:00:00+00:00 PythonOperator 2023-05-20T11:00:18.119854+00:00 2023-05-20T11:00:19.155429+00:00 0:00:01.035575 382660 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T11:00:15.212153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T09:00:00+00:00 TriggerDagRunOperator 2023-05-20T10:11:10.962637+00:00 2023-05-20T10:11:11.455049+00:00 0:00:00.492412 382648 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T10:11:08.484469+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T09:00:00+00:00 TriggerDagRunOperator 2023-05-20T10:11:10.946562+00:00 2023-05-20T10:11:11.434368+00:00 0:00:00.487806 382647 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T10:11:08.484434+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T09:00:00+00:00 EmrJobFlowSensor 2023-05-20T10:00:52.190296+00:00 2023-05-20T10:10:54.131383+00:00 0:10:01.941087 382641 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T10:00:49.784871+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T10:00:30.369677+00:00 2023-05-20T10:00:31.355776+00:00 0:00:00.986099 382639 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T10:00:27.790612+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T09:00:00+00:00 PythonOperator 2023-05-20T10:00:10.540349+00:00 2023-05-20T10:00:11.621599+00:00 0:00:01.081250 382636 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T10:00:07.496551+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T08:00:00+00:00 TriggerDagRunOperator 2023-05-20T09:19:44.180419+00:00 2023-05-20T09:19:44.653783+00:00 0:00:00.473364 382624 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T09:19:41.382407+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T08:00:00+00:00 TriggerDagRunOperator 2023-05-20T09:19:44.169325+00:00 2023-05-20T09:19:44.659898+00:00 0:00:00.490573 382623 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T09:19:41.382362+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T08:00:00+00:00 EmrJobFlowSensor 2023-05-20T09:09:29.616209+00:00 2023-05-20T09:19:31.738505+00:00 0:10:02.122296 382618 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T09:09:27.316158+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T09:09:09.542361+00:00 2023-05-20T09:09:10.491821+00:00 0:00:00.949460 382615 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T09:09:07.251784+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T08:00:00+00:00 PythonOperator 2023-05-20T09:08:48.095287+00:00 2023-05-20T09:08:49.168046+00:00 0:00:01.072759 382612 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T09:08:45.234892+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T07:00:00+00:00 TriggerDagRunOperator 2023-05-20T08:19:01.189257+00:00 2023-05-20T08:19:01.663856+00:00 0:00:00.474599 382599 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T08:18:58.921153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T07:00:00+00:00 TriggerDagRunOperator 2023-05-20T08:19:01.139289+00:00 2023-05-20T08:19:01.609541+00:00 0:00:00.470252 382598 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T08:18:58.921181+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T07:00:00+00:00 EmrJobFlowSensor 2023-05-20T08:01:05.416717+00:00 2023-05-20T08:11:07.306429+00:00 0:10:01.889712 382593 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T08:01:02.919816+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T08:00:43.301586+00:00 2023-05-20T08:00:44.349850+00:00 0:00:01.048264 382591 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T08:00:40.880408+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T07:00:00+00:00 PythonOperator 2023-05-20T08:00:23.058010+00:00 2023-05-20T08:00:24.018981+00:00 0:00:00.960971 382589 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T08:00:20.807291+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T06:00:00+00:00 TriggerDagRunOperator 2023-05-20T07:16:51.897390+00:00 2023-05-20T07:16:52.362556+00:00 0:00:00.465166 382577 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T07:16:49.018662+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T06:00:00+00:00 TriggerDagRunOperator 2023-05-20T07:16:51.840660+00:00 2023-05-20T07:16:52.310354+00:00 0:00:00.469694 382576 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T07:16:49.018690+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T06:00:00+00:00 EmrJobFlowSensor 2023-05-20T07:06:27.875941+00:00 2023-05-20T07:16:29.804455+00:00 0:10:01.928514 382573 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T07:06:25.628147+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T07:06:06.314872+00:00 2023-05-20T07:06:07.291551+00:00 0:00:00.976679 382570 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T07:06:03.607058+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T06:00:00+00:00 PythonOperator 2023-05-20T07:05:45.962005+00:00 2023-05-20T07:05:47.034666+00:00 0:00:01.072661 382567 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T07:05:43.600458+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T05:00:00+00:00 TriggerDagRunOperator 2023-05-20T06:11:32.510100+00:00 2023-05-20T06:11:32.964817+00:00 0:00:00.454717 382554 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T06:11:30.171213+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T05:00:00+00:00 TriggerDagRunOperator 2023-05-20T06:11:32.423255+00:00 2023-05-20T06:11:32.942864+00:00 0:00:00.519609 382553 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T06:11:30.171183+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T05:00:00+00:00 EmrJobFlowSensor 2023-05-20T06:01:07.509052+00:00 2023-05-20T06:11:09.480962+00:00 0:10:01.971910 382547 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T06:01:05.220792+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T06:00:45.425774+00:00 2023-05-20T06:00:46.363343+00:00 0:00:00.937569 382545 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T06:00:43.127691+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T05:00:00+00:00 PythonOperator 2023-05-20T06:00:23.649947+00:00 2023-05-20T06:00:24.696840+00:00 0:00:01.046893 382543 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T06:00:21.109134+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T04:00:00+00:00 TriggerDagRunOperator 2023-05-20T05:12:12.364513+00:00 2023-05-20T05:12:12.826020+00:00 0:00:00.461507 382530 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T05:12:09.413373+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T04:00:00+00:00 TriggerDagRunOperator 2023-05-20T05:12:12.300649+00:00 2023-05-20T05:12:12.811026+00:00 0:00:00.510377 382529 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T05:12:09.413344+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T04:00:00+00:00 EmrJobFlowSensor 2023-05-20T05:01:54.134668+00:00 2023-05-20T05:11:56.073864+00:00 0:10:01.939196 382524 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T05:01:51.714352+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T05:01:31.942321+00:00 2023-05-20T05:01:32.931231+00:00 0:00:00.988910 382522 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T05:01:29.633109+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T04:00:00+00:00 PythonOperator 2023-05-20T05:00:21.757914+00:00 2023-05-20T05:00:22.708313+00:00 0:00:00.950399 382518 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T05:00:19.552437+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T03:00:00+00:00 TriggerDagRunOperator 2023-05-20T04:18:51.458850+00:00 2023-05-20T04:18:51.923187+00:00 0:00:00.464337 382506 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T04:18:48.603427+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T03:00:00+00:00 TriggerDagRunOperator 2023-05-20T04:18:51.423676+00:00 2023-05-20T04:18:51.856467+00:00 0:00:00.432791 382505 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T04:18:48.603455+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T03:00:00+00:00 EmrJobFlowSensor 2023-05-20T04:06:13.269076+00:00 2023-05-20T04:16:15.215033+00:00 0:10:01.945957 382500 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T04:06:10.983044+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T04:05:53.143658+00:00 2023-05-20T04:05:54.200912+00:00 0:00:01.057254 382498 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T04:05:50.946965+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T03:00:00+00:00 PythonOperator 2023-05-20T04:05:31.768077+00:00 2023-05-20T04:05:32.882148+00:00 0:00:01.114071 382494 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T04:05:28.841005+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T02:00:00+00:00 TriggerDagRunOperator 2023-05-20T03:11:30.959694+00:00 2023-05-20T03:11:31.439758+00:00 0:00:00.480064 382483 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T03:11:28.627282+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T02:00:00+00:00 TriggerDagRunOperator 2023-05-20T03:11:30.919234+00:00 2023-05-20T03:11:31.380238+00:00 0:00:00.461004 382482 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T03:11:28.627249+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T02:00:00+00:00 EmrJobFlowSensor 2023-05-20T03:01:06.318814+00:00 2023-05-20T03:11:08.209413+00:00 0:10:01.890599 382476 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T03:01:04.088144+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T03:00:46.520738+00:00 2023-05-20T03:00:47.520436+00:00 0:00:00.999698 382474 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T03:00:44.069281+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T02:00:00+00:00 PythonOperator 2023-05-20T03:00:24.960511+00:00 2023-05-20T03:00:26.072569+00:00 0:00:01.112058 382472 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T03:00:22.101688+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T01:00:00+00:00 TriggerDagRunOperator 2023-05-20T02:11:07.024125+00:00 2023-05-20T02:11:07.487966+00:00 0:00:00.463841 382458 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T02:11:04.342441+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T01:00:00+00:00 TriggerDagRunOperator 2023-05-20T02:11:06.948203+00:00 2023-05-20T02:11:07.419789+00:00 0:00:00.471586 382457 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T02:11:04.342391+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T01:00:00+00:00 EmrJobFlowSensor 2023-05-20T02:00:56.646789+00:00 2023-05-20T02:10:58.539033+00:00 0:10:01.892244 382450 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T02:00:54.282684+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T02:00:34.659166+00:00 2023-05-20T02:00:35.845762+00:00 0:00:01.186596 382448 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T02:00:32.202611+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T01:00:00+00:00 PythonOperator 2023-05-20T02:00:15.122348+00:00 2023-05-20T02:00:16.235550+00:00 0:00:01.113202 382446 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T02:00:12.195675+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-20T00:00:00+00:00 TriggerDagRunOperator 2023-05-20T01:11:14.615504+00:00 2023-05-20T01:11:15.137844+00:00 0:00:00.522340 382427 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T01:11:11.679168+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-20T00:00:00+00:00 TriggerDagRunOperator 2023-05-20T01:11:14.330011+00:00 2023-05-20T01:11:14.814465+00:00 0:00:00.484454 382426 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T01:11:11.679197+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-20T00:00:00+00:00 EmrJobFlowSensor 2023-05-20T01:02:02.649753+00:00 2023-05-20T01:11:04.390617+00:00 0:09:01.740864 382420 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T01:02:00.315470+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-20T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T01:01:42.586625+00:00 2023-05-20T01:01:43.557932+00:00 0:00:00.971307 382418 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T01:01:40.254188+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-20T00:00:00+00:00 PythonOperator 2023-05-20T01:01:20.686947+00:00 2023-05-20T01:01:21.763652+00:00 0:00:01.076705 382416 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T01:01:18.241027+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T23:00:00+00:00 TriggerDagRunOperator 2023-05-20T00:11:57.084915+00:00 2023-05-20T00:11:57.536636+00:00 0:00:00.451721 382401 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T00:11:54.667532+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T23:00:00+00:00 TriggerDagRunOperator 2023-05-20T00:11:57.018848+00:00 2023-05-20T00:11:57.483261+00:00 0:00:00.464413 382400 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-20T00:11:54.667503+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T23:00:00+00:00 EmrJobFlowSensor 2023-05-20T00:01:37.941740+00:00 2023-05-20T00:11:39.916468+00:00 0:10:01.974728 382393 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-20T00:01:35.704749+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-20T00:01:15.930913+00:00 2023-05-20T00:01:16.895952+00:00 0:00:00.965039 382391 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-20T00:01:13.634090+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T23:00:00+00:00 PythonOperator 2023-05-20T00:00:56.117878+00:00 2023-05-20T00:00:57.243519+00:00 0:00:01.125641 382389 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-20T00:00:53.620402+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T22:00:00+00:00 TriggerDagRunOperator 2023-05-19T23:16:42.289449+00:00 2023-05-19T23:16:42.768583+00:00 0:00:00.479134 382376 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T23:16:39.835268+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T22:00:00+00:00 TriggerDagRunOperator 2023-05-19T23:16:42.291203+00:00 2023-05-19T23:16:42.773447+00:00 0:00:00.482244 382375 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T23:16:39.835239+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T22:00:00+00:00 EmrJobFlowSensor 2023-05-19T23:00:58.020901+00:00 2023-05-19T23:10:59.925454+00:00 0:10:01.904553 382367 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T23:00:55.794192+00:00 2 default_pool