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-22T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T11:00:37.977981+00:00 2023-05-22T11:00:38.938865+00:00 0:00:00.960884 383865 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T11:00:35.481857+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T10:00:00+00:00 PythonOperator 2023-05-22T11:00:16.090766+00:00 2023-05-22T11:00:17.205210+00:00 0:00:01.114444 383863 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T11:00:13.387816+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T09:00:00+00:00 TriggerDagRunOperator 2023-05-22T10:11:19.366902+00:00 2023-05-22T10:11:19.854595+00:00 0:00:00.487693 383849 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T10:11:16.955618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T09:00:00+00:00 TriggerDagRunOperator 2023-05-22T10:11:19.341969+00:00 2023-05-22T10:11:19.773593+00:00 0:00:00.431624 383848 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T10:11:16.955664+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T09:00:00+00:00 EmrJobFlowSensor 2023-05-22T10:01:05.541038+00:00 2023-05-22T10:11:07.413391+00:00 0:10:01.872353 383842 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T10:01:03.268862+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T10:00:43.586853+00:00 2023-05-22T10:00:44.612142+00:00 0:00:01.025289 383840 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T10:00:41.247939+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T09:00:00+00:00 PythonOperator 2023-05-22T10:00:21.882227+00:00 2023-05-22T10:00:22.851537+00:00 0:00:00.969310 383838 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T10:00:19.314045+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T08:00:00+00:00 TriggerDagRunOperator 2023-05-22T09:12:05.642269+00:00 2023-05-22T09:12:06.110482+00:00 0:00:00.468213 383824 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T09:12:03.189858+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T08:00:00+00:00 TriggerDagRunOperator 2023-05-22T09:12:05.578451+00:00 2023-05-22T09:12:06.010555+00:00 0:00:00.432104 383823 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T09:12:03.189892+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T08:00:00+00:00 EmrJobFlowSensor 2023-05-22T09:00:54.384217+00:00 2023-05-22T09:11:56.524221+00:00 0:11:02.140004 383814 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T09:00:52.125843+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T09:00:32.385100+00:00 2023-05-22T09:00:33.331245+00:00 0:00:00.946145 383813 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T09:00:30.134920+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T08:00:00+00:00 PythonOperator 2023-05-22T09:00:10.718623+00:00 2023-05-22T09:00:11.725132+00:00 0:00:01.006509 383811 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T09:00:08.086051+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T07:00:00+00:00 TriggerDagRunOperator 2023-05-22T08:15:44.558371+00:00 2023-05-22T08:15:45.164977+00:00 0:00:00.606606 383799 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T08:15:41.469171+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T07:00:00+00:00 TriggerDagRunOperator 2023-05-22T08:15:44.198306+00:00 2023-05-22T08:15:44.657758+00:00 0:00:00.459452 383798 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T08:15:41.469134+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T07:00:00+00:00 EmrJobFlowSensor 2023-05-22T08:00:53.723343+00:00 2023-05-22T08:10:55.993703+00:00 0:10:02.270360 383790 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T08:00:51.208109+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T08:00:33.731876+00:00 2023-05-22T08:00:34.714654+00:00 0:00:00.982778 383788 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T08:00:31.198562+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T07:00:00+00:00 PythonOperator 2023-05-22T08:00:11.788529+00:00 2023-05-22T08:00:13.896516+00:00 0:00:02.107987 383786 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T08:00:09.134630+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T06:00:00+00:00 TriggerDagRunOperator 2023-05-22T07:11:15.127626+00:00 2023-05-22T07:11:15.592786+00:00 0:00:00.465160 383773 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T07:11:12.722674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T06:00:00+00:00 TriggerDagRunOperator 2023-05-22T07:11:15.061337+00:00 2023-05-22T07:11:15.559464+00:00 0:00:00.498127 383772 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T07:11:12.722706+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T06:00:00+00:00 EmrJobFlowSensor 2023-05-22T07:01:00.331366+00:00 2023-05-22T07:11:02.475068+00:00 0:10:02.143702 383766 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T07:00:57.713897+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T07:00:38.084789+00:00 2023-05-22T07:00:39.037509+00:00 0:00:00.952720 383764 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T07:00:35.706377+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T06:00:00+00:00 PythonOperator 2023-05-22T07:00:17.954231+00:00 2023-05-22T07:00:19.200667+00:00 0:00:01.246436 383762 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T07:00:15.671726+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T05:00:00+00:00 TriggerDagRunOperator 2023-05-22T06:22:36.521104+00:00 2023-05-22T06:22:37.022827+00:00 0:00:00.501723 383746 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T06:22:33.463752+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T05:00:00+00:00 TriggerDagRunOperator 2023-05-22T06:22:36.391635+00:00 2023-05-22T06:22:36.823906+00:00 0:00:00.432271 383745 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T06:22:33.463717+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T05:00:00+00:00 EmrJobFlowSensor 2023-05-22T06:01:00.325579+00:00 2023-05-22T06:11:02.670664+00:00 0:10:02.345085 383741 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T06:00:57.523800+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T06:00:39.825346+00:00 2023-05-22T06:00:40.743461+00:00 0:00:00.918115 383740 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T06:00:37.456544+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T05:00:00+00:00 PythonOperator 2023-05-22T06:00:18.007599+00:00 2023-05-22T06:00:19.153536+00:00 0:00:01.145937 383739 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T06:00:15.437355+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T04:00:00+00:00 TriggerDagRunOperator 2023-05-22T05:13:59.612984+00:00 2023-05-22T05:14:00.321679+00:00 0:00:00.708695 383725 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T05:13:56.987310+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T04:00:00+00:00 TriggerDagRunOperator 2023-05-22T05:13:59.610263+00:00 2023-05-22T05:14:00.335434+00:00 0:00:00.725171 383724 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T05:13:56.987338+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T04:00:00+00:00 EmrJobFlowSensor 2023-05-22T05:03:35.368934+00:00 2023-05-22T05:13:37.317742+00:00 0:10:01.948808 383718 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T05:03:32.710022+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T05:03:12.922185+00:00 2023-05-22T05:03:14.056750+00:00 0:00:01.134565 383716 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T05:03:10.656918+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T04:00:00+00:00 PythonOperator 2023-05-22T05:02:52.916223+00:00 2023-05-22T05:02:54.102518+00:00 0:00:01.186295 383714 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T05:02:50.635781+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T03:00:00+00:00 TriggerDagRunOperator 2023-05-22T04:11:18.200376+00:00 2023-05-22T04:11:18.763619+00:00 0:00:00.563243 383701 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T04:11:15.529903+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T03:00:00+00:00 TriggerDagRunOperator 2023-05-22T04:11:18.143070+00:00 2023-05-22T04:11:18.664012+00:00 0:00:00.520942 383700 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T04:11:15.529859+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T03:00:00+00:00 EmrJobFlowSensor 2023-05-22T04:00:54.406914+00:00 2023-05-22T04:10:56.370751+00:00 0:10:01.963837 383693 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T04:00:52.125607+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T04:00:32.692036+00:00 2023-05-22T04:00:33.679163+00:00 0:00:00.987127 383692 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T04:00:30.196064+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T03:00:00+00:00 PythonOperator 2023-05-22T04:00:13.360491+00:00 2023-05-22T04:00:14.381223+00:00 0:00:01.020732 383690 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T04:00:10.086832+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T02:00:00+00:00 TriggerDagRunOperator 2023-05-22T03:16:12.655104+00:00 2023-05-22T03:16:13.161865+00:00 0:00:00.506761 383677 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T03:16:09.334372+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T02:00:00+00:00 TriggerDagRunOperator 2023-05-22T03:16:12.315912+00:00 2023-05-22T03:16:12.776973+00:00 0:00:00.461061 383676 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T03:16:09.334341+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T02:00:00+00:00 EmrJobFlowSensor 2023-05-22T03:00:57.635481+00:00 2023-05-22T03:10:59.889779+00:00 0:10:02.254298 383668 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T03:00:55.246344+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T03:00:36.049960+00:00 2023-05-22T03:00:37.033895+00:00 0:00:00.983935 383666 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T03:00:33.383654+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T02:00:00+00:00 PythonOperator 2023-05-22T03:00:16.087634+00:00 2023-05-22T03:00:17.133011+00:00 0:00:01.045377 383664 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T03:00:12.990397+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T01:00:00+00:00 TriggerDagRunOperator 2023-05-22T02:11:08.911197+00:00 2023-05-22T02:11:09.374357+00:00 0:00:00.463160 383651 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T02:11:06.114540+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T01:00:00+00:00 TriggerDagRunOperator 2023-05-22T02:11:08.806318+00:00 2023-05-22T02:11:09.292998+00:00 0:00:00.486680 383650 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T02:11:06.114493+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T01:00:00+00:00 EmrJobFlowSensor 2023-05-22T02:00:58.793232+00:00 2023-05-22T02:11:00.739226+00:00 0:10:01.945994 383643 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T02:00:56.420768+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T02:00:38.755958+00:00 2023-05-22T02:00:39.733264+00:00 0:00:00.977306 383641 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T02:00:36.404745+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T01:00:00+00:00 PythonOperator 2023-05-22T02:00:16.620539+00:00 2023-05-22T02:00:17.768790+00:00 0:00:01.148251 383639 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T02:00:14.307688+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-22T00:00:00+00:00 TriggerDagRunOperator 2023-05-22T01:11:23.980312+00:00 2023-05-22T01:11:24.602483+00:00 0:00:00.622171 383619 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T01:11:20.695688+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-22T00:00:00+00:00 TriggerDagRunOperator 2023-05-22T01:11:23.633954+00:00 2023-05-22T01:11:24.178661+00:00 0:00:00.544707 383618 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T01:11:20.695720+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-22T00:00:00+00:00 EmrJobFlowSensor 2023-05-22T01:01:02.186355+00:00 2023-05-22T01:11:04.191092+00:00 0:10:02.004737 383611 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T01:00:59.934405+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-22T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T01:00:42.141502+00:00 2023-05-22T01:00:43.083411+00:00 0:00:00.941909 383609 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T01:00:39.909510+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-22T00:00:00+00:00 PythonOperator 2023-05-22T01:00:20.150130+00:00 2023-05-22T01:00:21.304431+00:00 0:00:01.154301 383607 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T01:00:17.858950+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T23:00:00+00:00 TriggerDagRunOperator 2023-05-22T00:11:01.623187+00:00 2023-05-22T00:11:02.076525+00:00 0:00:00.453338 383593 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T00:10:58.523737+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T23:00:00+00:00 TriggerDagRunOperator 2023-05-22T00:11:01.607605+00:00 2023-05-22T00:11:02.101096+00:00 0:00:00.493491 383592 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-22T00:10:58.523781+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T23:00:00+00:00 EmrJobFlowSensor 2023-05-22T00:00:52.428869+00:00 2023-05-22T00:10:54.355160+00:00 0:10:01.926291 383584 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-22T00:00:50.219437+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-22T00:00:32.574032+00:00 2023-05-22T00:00:33.606125+00:00 0:00:01.032093 383582 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-22T00:00:30.183263+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T23:00:00+00:00 PythonOperator 2023-05-22T00:00:10.953040+00:00 2023-05-22T00:00:11.941400+00:00 0:00:00.988360 383580 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-22T00:00:07.988609+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T22:00:00+00:00 TriggerDagRunOperator 2023-05-21T23:11:17.837963+00:00 2023-05-21T23:11:18.356372+00:00 0:00:00.518409 383567 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T23:11:15.318522+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T22:00:00+00:00 TriggerDagRunOperator 2023-05-21T23:11:17.835216+00:00 2023-05-21T23:11:18.288806+00:00 0:00:00.453590 383566 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T23:11:15.318568+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T22:00:00+00:00 EmrJobFlowSensor 2023-05-21T23:01:02.618709+00:00 2023-05-21T23:11:04.553541+00:00 0:10:01.934832 383559 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T23:01:00.228514+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T23:00:40.825841+00:00 2023-05-21T23:00:41.726881+00:00 0:00:00.901040 383556 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T23:00:38.085648+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T22:00:00+00:00 PythonOperator 2023-05-21T23:00:20.364075+00:00 2023-05-21T23:00:21.344472+00:00 0:00:00.980397 383553 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T23:00:18.066097+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T21:00:00+00:00 TriggerDagRunOperator 2023-05-21T22:11:30.264472+00:00 2023-05-21T22:11:30.773443+00:00 0:00:00.508971 383538 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T22:11:27.102493+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T21:00:00+00:00 TriggerDagRunOperator 2023-05-21T22:11:30.185603+00:00 2023-05-21T22:11:30.708123+00:00 0:00:00.522520 383537 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T22:11:27.102535+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T21:00:00+00:00 EmrJobFlowSensor 2023-05-21T22:01:03.928476+00:00 2023-05-21T22:11:05.836234+00:00 0:10:01.907758 383530 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T22:01:01.692705+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T22:00:41.827657+00:00 2023-05-21T22:00:42.710444+00:00 0:00:00.882787 383528 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T22:00:39.633683+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T21:00:00+00:00 PythonOperator 2023-05-21T22:00:19.883601+00:00 2023-05-21T22:00:21.025296+00:00 0:00:01.141695 383526 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T22:00:17.609786+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T20:00:00+00:00 TriggerDagRunOperator 2023-05-21T21:11:23.221015+00:00 2023-05-21T21:11:23.703166+00:00 0:00:00.482151 383512 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T21:11:20.601406+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T20:00:00+00:00 TriggerDagRunOperator 2023-05-21T21:11:23.125797+00:00 2023-05-21T21:11:23.635537+00:00 0:00:00.509740 383511 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T21:11:20.601378+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T20:00:00+00:00 EmrJobFlowSensor 2023-05-21T21:00:57.321775+00:00 2023-05-21T21:10:59.284614+00:00 0:10:01.962839 383504 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T21:00:55.094475+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T21:00:37.229006+00:00 2023-05-21T21:00:38.200351+00:00 0:00:00.971345 383502 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T21:00:35.071490+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T20:00:00+00:00 PythonOperator 2023-05-21T21:00:16.052906+00:00 2023-05-21T21:00:17.003224+00:00 0:00:00.950318 383500 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T21:00:13.055799+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T19:00:00+00:00 TriggerDagRunOperator 2023-05-21T20:11:06.193397+00:00 2023-05-21T20:11:06.699523+00:00 0:00:00.506126 383486 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T20:11:03.693251+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T19:00:00+00:00 TriggerDagRunOperator 2023-05-21T20:11:06.144220+00:00 2023-05-21T20:11:06.601525+00:00 0:00:00.457305 383485 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T20:11:03.693210+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T19:00:00+00:00 EmrJobFlowSensor 2023-05-21T20:01:00.452186+00:00 2023-05-21T20:11:02.512649+00:00 0:10:02.060463 383478 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T20:00:58.030419+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T20:00:38.267422+00:00 2023-05-21T20:00:39.194541+00:00 0:00:00.927119 383476 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T20:00:36.003591+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T19:00:00+00:00 PythonOperator 2023-05-21T20:00:16.422950+00:00 2023-05-21T20:00:17.524803+00:00 0:00:01.101853 383474 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T20:00:13.965078+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T18:00:00+00:00 TriggerDagRunOperator 2023-05-21T19:11:03.909397+00:00 2023-05-21T19:11:04.382747+00:00 0:00:00.473350 383458 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T19:11:01.407800+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T18:00:00+00:00 TriggerDagRunOperator 2023-05-21T19:11:03.874593+00:00 2023-05-21T19:11:04.312873+00:00 0:00:00.438280 383457 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T19:11:01.407833+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T18:00:00+00:00 EmrJobFlowSensor 2023-05-21T19:00:56.828359+00:00 2023-05-21T19:10:58.754159+00:00 0:10:01.925800 383449 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T19:00:54.525046+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T19:00:36.751272+00:00 2023-05-21T19:00:37.653630+00:00 0:00:00.902358 383448 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T19:00:34.516613+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T18:00:00+00:00 PythonOperator 2023-05-21T19:00:14.880514+00:00 2023-05-21T19:00:15.978838+00:00 0:00:01.098324 383446 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T19:00:12.456067+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T17:00:00+00:00 TriggerDagRunOperator 2023-05-21T18:11:09.431507+00:00 2023-05-21T18:11:09.925923+00:00 0:00:00.494416 383431 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T18:11:07.128662+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T17:00:00+00:00 TriggerDagRunOperator 2023-05-21T18:11:09.371611+00:00 2023-05-21T18:11:09.858573+00:00 0:00:00.486962 383430 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T18:11:07.128635+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T17:00:00+00:00 EmrJobFlowSensor 2023-05-21T18:00:51.036188+00:00 2023-05-21T18:10:53.018190+00:00 0:10:01.982002 383422 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T18:00:48.834578+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T18:00:31.268959+00:00 2023-05-21T18:00:32.156138+00:00 0:00:00.887179 383421 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T18:00:28.891479+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T17:00:00+00:00 PythonOperator 2023-05-21T18:00:09.828779+00:00 2023-05-21T18:00:10.808337+00:00 0:00:00.979558 383419 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T18:00:06.686563+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T16:00:00+00:00 TriggerDagRunOperator 2023-05-21T17:11:14.860226+00:00 2023-05-21T17:11:15.325127+00:00 0:00:00.464901 383406 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T17:11:12.094182+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T16:00:00+00:00 TriggerDagRunOperator 2023-05-21T17:11:14.834652+00:00 2023-05-21T17:11:15.319711+00:00 0:00:00.485059 383405 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T17:11:12.094224+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T16:00:00+00:00 EmrJobFlowSensor 2023-05-21T17:01:02.571939+00:00 2023-05-21T17:11:04.517923+00:00 0:10:01.945984 383395 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T17:01:00.270628+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T17:00:42.468371+00:00 2023-05-21T17:00:43.478019+00:00 0:00:01.009648 383394 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T17:00:40.253527+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T16:00:00+00:00 PythonOperator 2023-05-21T17:00:20.747034+00:00 2023-05-21T17:00:21.766192+00:00 0:00:01.019158 383393 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T17:00:18.293804+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T15:00:00+00:00 TriggerDagRunOperator 2023-05-21T16:11:30.960322+00:00 2023-05-21T16:11:31.429217+00:00 0:00:00.468895 383380 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T16:11:28.111461+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T15:00:00+00:00 TriggerDagRunOperator 2023-05-21T16:11:30.939349+00:00 2023-05-21T16:11:31.403493+00:00 0:00:00.464144 383379 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T16:11:28.111490+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T15:00:00+00:00 EmrJobFlowSensor 2023-05-21T16:01:05.913468+00:00 2023-05-21T16:11:07.795761+00:00 0:10:01.882293 383371 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T16:01:03.388389+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-21T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-21T16:00:43.549042+00:00 2023-05-21T16:00:44.457970+00:00 0:00:00.908928 383369 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-21T16:00:41.227076+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-21T15:00:00+00:00 PythonOperator 2023-05-21T16:00:24.054490+00:00 2023-05-21T16:00:25.136079+00:00 0:00:01.081589 383367 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-21T16:00:21.213437+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-21T14:00:00+00:00 TriggerDagRunOperator 2023-05-21T15:29:45.834203+00:00 2023-05-21T15:29:46.308264+00:00 0:00:00.474061 383356 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T15:29:43.280980+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-21T14:00:00+00:00 TriggerDagRunOperator 2023-05-21T15:29:45.817438+00:00 2023-05-21T15:29:46.268749+00:00 0:00:00.451311 383355 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-21T15:29:43.280948+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-21T14:00:00+00:00 EmrJobFlowSensor 2023-05-21T15:19:28.763105+00:00 2023-05-21T15:29:30.679721+00:00 0:10:01.916616 383349 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-21T15:19:26.450975+00:00 2 default_pool