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-06-05T14:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T15:00:27.836184+00:00 2023-06-05T15:00:28.706888+00:00 0:00:00.870704 391511 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T15:00:25.797041+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T14:00:00+00:00 PythonOperator 2023-06-05T15:00:07.852698+00:00 2023-06-05T15:00:08.787660+00:00 0:00:00.934962 391509 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T15:00:05.774273+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T13:00:00+00:00 TriggerDagRunOperator 2023-06-05T14:51:05.859135+00:00 2023-06-05T14:51:06.320839+00:00 0:00:00.461704 391504 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T14:51:03.664843+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T13:00:00+00:00 TriggerDagRunOperator 2023-06-05T14:51:05.792282+00:00 2023-06-05T14:51:06.222696+00:00 0:00:00.430414 391503 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T14:51:03.664872+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T13:00:00+00:00 EmrJobFlowSensor 2023-06-05T14:36:52.669457+00:00 2023-06-05T14:46:54.518273+00:00 0:10:01.848816 391500 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T14:36:50.644067+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T13:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T14:36:30.626817+00:00 2023-06-05T14:36:31.654585+00:00 0:00:01.027768 391496 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T14:36:28.625013+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T13:00:00+00:00 PythonOperator 2023-06-05T14:36:10.608001+00:00 2023-06-05T14:36:11.615479+00:00 0:00:01.007478 391494 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T14:36:08.608564+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T12:00:00+00:00 TriggerDagRunOperator 2023-06-05T13:14:04.352410+00:00 2023-06-05T13:14:04.761969+00:00 0:00:00.409559 391485 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T13:14:02.146273+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T12:00:00+00:00 TriggerDagRunOperator 2023-06-05T13:14:04.327032+00:00 2023-06-05T13:14:04.802678+00:00 0:00:00.475646 391484 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T13:14:02.146304+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T12:00:00+00:00 EmrJobFlowSensor 2023-06-05T13:01:55.340928+00:00 2023-06-05T13:11:56.950973+00:00 0:10:01.610045 391477 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T13:01:53.381926+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T12:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T13:01:33.311619+00:00 2023-06-05T13:01:34.189708+00:00 0:00:00.878089 391475 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T13:01:31.360052+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T12:00:00+00:00 PythonOperator 2023-06-05T13:01:13.630521+00:00 2023-06-05T13:01:14.613700+00:00 0:00:00.983179 391473 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T13:01:11.393189+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T11:00:00+00:00 TriggerDagRunOperator 2023-06-05T12:11:11.302018+00:00 2023-06-05T12:11:11.749259+00:00 0:00:00.447241 391465 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T12:11:09.115591+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T11:00:00+00:00 TriggerDagRunOperator 2023-06-05T12:11:11.265020+00:00 2023-06-05T12:11:11.673346+00:00 0:00:00.408326 391464 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T12:11:09.115563+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T11:00:00+00:00 EmrJobFlowSensor 2023-06-05T12:00:58.039604+00:00 2023-06-05T12:10:59.681718+00:00 0:10:01.642114 391458 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T12:00:56.015293+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T11:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T12:00:36.039559+00:00 2023-06-05T12:00:36.999974+00:00 0:00:00.960415 391456 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T12:00:33.993446+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T11:00:00+00:00 PythonOperator 2023-06-05T12:00:15.994822+00:00 2023-06-05T12:00:16.966901+00:00 0:00:00.972079 391454 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T12:00:13.976788+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T10:00:00+00:00 TriggerDagRunOperator 2023-06-05T11:25:29.332596+00:00 2023-06-05T11:25:29.763000+00:00 0:00:00.430404 391444 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T11:25:27.146504+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T10:00:00+00:00 TriggerDagRunOperator 2023-06-05T11:25:29.296309+00:00 2023-06-05T11:25:29.723728+00:00 0:00:00.427419 391443 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T11:25:27.146533+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T10:00:00+00:00 EmrJobFlowSensor 2023-06-05T11:15:12.536511+00:00 2023-06-05T11:25:14.526039+00:00 0:10:01.989528 391439 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T11:15:10.324801+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T10:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T11:14:50.340056+00:00 2023-06-05T11:14:51.212554+00:00 0:00:00.872498 391436 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T11:14:48.305424+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T10:00:00+00:00 PythonOperator 2023-06-05T11:14:30.721809+00:00 2023-06-05T11:14:31.707764+00:00 0:00:00.985955 391433 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T11:14:28.285569+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T09:00:00+00:00 TriggerDagRunOperator 2023-06-05T10:33:51.368856+00:00 2023-06-05T10:33:51.811219+00:00 0:00:00.442363 391426 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T10:33:49.066932+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T09:00:00+00:00 TriggerDagRunOperator 2023-06-05T10:33:51.336802+00:00 2023-06-05T10:33:51.753228+00:00 0:00:00.416426 391425 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T10:33:49.066961+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T09:00:00+00:00 EmrJobFlowSensor 2023-06-05T10:21:05.306933+00:00 2023-06-05T10:31:07.127982+00:00 0:10:01.821049 391420 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T10:21:03.316968+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T09:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T10:20:43.318515+00:00 2023-06-05T10:20:44.241911+00:00 0:00:00.923396 391417 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T10:20:41.295265+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T09:00:00+00:00 PythonOperator 2023-06-05T10:20:23.641826+00:00 2023-06-05T10:20:24.576979+00:00 0:00:00.935153 391414 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T10:20:21.281852+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T08:00:00+00:00 TriggerDagRunOperator 2023-06-05T09:20:55.311765+00:00 2023-06-05T09:20:55.722819+00:00 0:00:00.411054 391406 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T09:20:52.927121+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T08:00:00+00:00 TriggerDagRunOperator 2023-06-05T09:20:55.256921+00:00 2023-06-05T09:20:55.704325+00:00 0:00:00.447404 391405 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T09:20:52.927094+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T08:00:00+00:00 EmrJobFlowSensor 2023-06-05T09:08:11.939953+00:00 2023-06-05T09:18:13.691329+00:00 0:10:01.751376 391401 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T09:08:09.563153+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T08:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T09:07:49.802428+00:00 2023-06-05T09:07:50.707481+00:00 0:00:00.905053 391398 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T09:07:47.540916+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T08:00:00+00:00 PythonOperator 2023-06-05T09:00:22.004015+00:00 2023-06-05T09:00:22.989384+00:00 0:00:00.985369 391394 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T09:00:20.083906+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T07:00:00+00:00 TriggerDagRunOperator 2023-06-05T08:10:59.163899+00:00 2023-06-05T08:10:59.657331+00:00 0:00:00.493432 391384 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T08:10:57.032950+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T07:00:00+00:00 TriggerDagRunOperator 2023-06-05T08:10:59.062701+00:00 2023-06-05T08:10:59.538603+00:00 0:00:00.475902 391383 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T08:10:57.032919+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T07:00:00+00:00 EmrJobFlowSensor 2023-06-05T08:00:46.238289+00:00 2023-06-05T08:10:48.025929+00:00 0:10:01.787640 391376 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T08:00:44.001890+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T07:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T08:00:26.877515+00:00 2023-06-05T08:00:27.772478+00:00 0:00:00.894963 391375 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T08:00:24.002850+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T07:00:00+00:00 PythonOperator 2023-06-05T08:00:04.481704+00:00 2023-06-05T08:00:05.444198+00:00 0:00:00.962494 391373 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T08:00:01.998019+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T06:00:00+00:00 TriggerDagRunOperator 2023-06-05T07:11:26.950173+00:00 2023-06-05T07:11:27.416795+00:00 0:00:00.466622 391364 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T07:11:24.802234+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T06:00:00+00:00 TriggerDagRunOperator 2023-06-05T07:11:26.925211+00:00 2023-06-05T07:11:27.345694+00:00 0:00:00.420483 391363 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T07:11:24.802271+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T06:00:00+00:00 EmrJobFlowSensor 2023-06-05T07:01:02.772627+00:00 2023-06-05T07:11:04.437137+00:00 0:10:01.664510 391357 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T07:01:00.779217+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T06:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T07:00:40.729043+00:00 2023-06-05T07:00:41.983301+00:00 0:00:01.254258 391354 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T07:00:38.758454+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T06:00:00+00:00 PythonOperator 2023-06-05T07:00:18.908974+00:00 2023-06-05T07:00:19.901155+00:00 0:00:00.992181 391353 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T07:00:16.738213+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T05:00:00+00:00 TriggerDagRunOperator 2023-06-05T06:21:35.789543+00:00 2023-06-05T06:21:36.238154+00:00 0:00:00.448611 391345 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T06:21:33.425578+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T05:00:00+00:00 TriggerDagRunOperator 2023-06-05T06:21:35.784250+00:00 2023-06-05T06:21:36.238414+00:00 0:00:00.454164 391344 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T06:21:33.425605+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T05:00:00+00:00 EmrJobFlowSensor 2023-06-05T06:11:16.656155+00:00 2023-06-05T06:21:18.453867+00:00 0:10:01.797712 391341 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T06:11:14.452942+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T05:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T06:10:56.878337+00:00 2023-06-05T06:10:57.858306+00:00 0:00:00.979969 391338 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T06:10:54.434394+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T05:00:00+00:00 PythonOperator 2023-06-05T06:10:34.618893+00:00 2023-06-05T06:10:35.561388+00:00 0:00:00.942495 391335 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T06:10:32.413602+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T04:00:00+00:00 TriggerDagRunOperator 2023-06-05T05:28:54.571453+00:00 2023-06-05T05:28:55.019558+00:00 0:00:00.448105 391327 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T05:28:52.197486+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T04:00:00+00:00 TriggerDagRunOperator 2023-06-05T05:28:54.480903+00:00 2023-06-05T05:28:54.924204+00:00 0:00:00.443301 391326 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T05:28:52.197528+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T04:00:00+00:00 EmrJobFlowSensor 2023-06-05T05:18:49.142981+00:00 2023-06-05T05:28:50.840782+00:00 0:10:01.697801 391321 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T05:18:47.125359+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T04:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T05:18:29.058592+00:00 2023-06-05T05:18:30.142760+00:00 0:00:01.084168 391318 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T05:18:27.108016+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T04:00:00+00:00 PythonOperator 2023-06-05T05:18:07.440663+00:00 2023-06-05T05:18:08.342316+00:00 0:00:00.901653 391315 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T05:18:05.091108+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T03:00:00+00:00 TriggerDagRunOperator 2023-06-05T04:14:29.843115+00:00 2023-06-05T04:14:30.313355+00:00 0:00:00.470240 391305 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T04:14:27.399989+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T03:00:00+00:00 TriggerDagRunOperator 2023-06-05T04:14:29.819443+00:00 2023-06-05T04:14:30.270637+00:00 0:00:00.451194 391304 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T04:14:27.399954+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T03:00:00+00:00 EmrJobFlowSensor 2023-06-05T04:01:01.548311+00:00 2023-06-05T04:11:03.492328+00:00 0:10:01.944017 391301 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T04:00:59.534104+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T03:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T04:00:41.567770+00:00 2023-06-05T04:00:42.599570+00:00 0:00:01.031800 391299 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T04:00:39.517575+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T03:00:00+00:00 PythonOperator 2023-06-05T04:00:19.457572+00:00 2023-06-05T04:00:20.384800+00:00 0:00:00.927228 391297 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T04:00:17.497421+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T02:00:00+00:00 TriggerDagRunOperator 2023-06-05T03:11:18.686247+00:00 2023-06-05T03:11:19.142170+00:00 0:00:00.455923 391286 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T03:11:16.503150+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T02:00:00+00:00 TriggerDagRunOperator 2023-06-05T03:11:18.625987+00:00 2023-06-05T03:11:19.068849+00:00 0:00:00.442862 391285 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T03:11:16.503179+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T02:00:00+00:00 EmrJobFlowSensor 2023-06-05T03:00:54.175279+00:00 2023-06-05T03:10:56.238527+00:00 0:10:02.063248 391278 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T03:00:52.125815+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T02:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T03:00:34.122357+00:00 2023-06-05T03:00:35.073008+00:00 0:00:00.950651 391276 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T03:00:32.105845+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T02:00:00+00:00 PythonOperator 2023-06-05T03:00:12.229963+00:00 2023-06-05T03:00:13.346176+00:00 0:00:01.116213 391274 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T03:00:10.087685+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T01:00:00+00:00 TriggerDagRunOperator 2023-06-05T02:16:15.473033+00:00 2023-06-05T02:16:15.934014+00:00 0:00:00.460981 391267 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T02:16:13.282830+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T01:00:00+00:00 TriggerDagRunOperator 2023-06-05T02:16:15.430378+00:00 2023-06-05T02:16:15.862981+00:00 0:00:00.432603 391266 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T02:16:13.282794+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T01:00:00+00:00 EmrJobFlowSensor 2023-06-05T02:03:35.131291+00:00 2023-06-05T02:13:37.033534+00:00 0:10:01.902243 391259 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T02:03:33.133420+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T01:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T02:03:13.171965+00:00 2023-06-05T02:03:14.172322+00:00 0:00:01.000357 391257 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T02:03:11.112935+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T01:00:00+00:00 PythonOperator 2023-06-05T02:02:53.429135+00:00 2023-06-05T02:02:54.374669+00:00 0:00:00.945534 391255 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T02:02:51.103408+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T00:00:00+00:00 TriggerDagRunOperator 2023-06-05T01:21:33.289652+00:00 2023-06-05T01:21:33.723795+00:00 0:00:00.434143 391237 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T01:21:30.778636+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T00:00:00+00:00 TriggerDagRunOperator 2023-06-05T01:21:33.214527+00:00 2023-06-05T01:21:33.626575+00:00 0:00:00.412048 391236 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T01:21:30.778672+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T00:00:00+00:00 EmrJobFlowSensor 2023-06-05T01:10:05.599059+00:00 2023-06-05T01:20:07.565852+00:00 0:10:01.966793 391232 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T01:10:03.689934+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T00:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T01:09:45.695734+00:00 2023-06-05T01:09:46.612773+00:00 0:00:00.917039 391229 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T01:09:43.633191+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T00:00:00+00:00 PythonOperator 2023-06-05T01:09:23.623588+00:00 2023-06-05T01:09:24.553010+00:00 0:00:00.929422 391226 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T01:09:21.614030+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T23:00:00+00:00 TriggerDagRunOperator 2023-06-05T00:11:08.166161+00:00 2023-06-05T00:11:08.607860+00:00 0:00:00.441699 391217 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T00:11:05.976037+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T23:00:00+00:00 TriggerDagRunOperator 2023-06-05T00:11:08.110312+00:00 2023-06-05T00:11:08.514089+00:00 0:00:00.403777 391216 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T00:11:05.976008+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T23:00:00+00:00 EmrJobFlowSensor 2023-06-05T00:00:59.142743+00:00 2023-06-05T00:11:00.831406+00:00 0:10:01.688663 391210 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T00:00:57.104802+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T00:00:39.091160+00:00 2023-06-05T00:00:39.953036+00:00 0:00:00.861876 391208 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T00:00:37.027455+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T23:00:00+00:00 PythonOperator 2023-06-05T00:00:17.030459+00:00 2023-06-05T00:00:17.970019+00:00 0:00:00.939560 391206 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T00:00:15.010564+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T22:00:00+00:00 TriggerDagRunOperator 2023-06-04T23:11:11.369852+00:00 2023-06-04T23:11:11.867440+00:00 0:00:00.497588 391194 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T23:11:09.125010+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T22:00:00+00:00 TriggerDagRunOperator 2023-06-04T23:11:11.338683+00:00 2023-06-04T23:11:11.793030+00:00 0:00:00.454347 391193 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T23:11:09.124969+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T22:00:00+00:00 EmrJobFlowSensor 2023-06-04T23:00:55.131353+00:00 2023-06-04T23:10:57.046576+00:00 0:10:01.915223 391186 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T23:00:52.903927+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T22:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T23:00:33.072576+00:00 2023-06-04T23:00:33.966851+00:00 0:00:00.894275 391183 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T23:00:30.938155+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T22:00:00+00:00 PythonOperator 2023-06-04T23:00:11.019569+00:00 2023-06-04T23:00:11.966566+00:00 0:00:00.946997 391180 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T23:00:08.865290+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T21:00:00+00:00 TriggerDagRunOperator 2023-06-04T22:11:24.583673+00:00 2023-06-04T22:11:25.061412+00:00 0:00:00.477739 391168 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T22:11:22.349287+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T21:00:00+00:00 TriggerDagRunOperator 2023-06-04T22:11:24.487515+00:00 2023-06-04T22:11:24.921615+00:00 0:00:00.434100 391167 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T22:11:22.349259+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T21:00:00+00:00 EmrJobFlowSensor 2023-06-04T22:00:58.792514+00:00 2023-06-04T22:11:00.514429+00:00 0:10:01.721915 391161 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T22:00:56.786957+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T21:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T22:00:36.800537+00:00 2023-06-04T22:00:37.770630+00:00 0:00:00.970093 391159 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T22:00:34.761832+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T21:00:00+00:00 PythonOperator 2023-06-04T22:00:14.767912+00:00 2023-06-04T22:00:15.759396+00:00 0:00:00.991484 391157 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T22:00:12.745825+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T20:00:00+00:00 TriggerDagRunOperator 2023-06-04T21:11:09.192584+00:00 2023-06-04T21:11:09.638429+00:00 0:00:00.445845 391145 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T21:11:06.899224+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T20:00:00+00:00 TriggerDagRunOperator 2023-06-04T21:11:09.119768+00:00 2023-06-04T21:11:09.545134+00:00 0:00:00.425366 391144 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T21:11:06.899196+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T20:00:00+00:00 EmrJobFlowSensor 2023-06-04T21:00:53.722080+00:00 2023-06-04T21:10:55.537821+00:00 0:10:01.815741 391137 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T21:00:51.648747+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T20:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T21:00:33.760466+00:00 2023-06-04T21:00:34.710438+00:00 0:00:00.949972 391135 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T21:00:31.687517+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T20:00:00+00:00 PythonOperator 2023-06-04T21:00:11.897930+00:00 2023-06-04T21:00:12.848748+00:00 0:00:00.950818 391133 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T21:00:09.607907+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T19:00:00+00:00 TriggerDagRunOperator 2023-06-04T20:10:58.620176+00:00 2023-06-04T20:10:59.075599+00:00 0:00:00.455423 391122 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T20:10:56.288221+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T19:00:00+00:00 TriggerDagRunOperator 2023-06-04T20:10:58.494748+00:00 2023-06-04T20:10:58.885171+00:00 0:00:00.390423 391121 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T20:10:56.288249+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T19:00:00+00:00 EmrJobFlowSensor 2023-06-04T20:00:45.369773+00:00 2023-06-04T20:10:47.157482+00:00 0:10:01.787709 391114 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T20:00:43.277915+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T19:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T20:00:25.220760+00:00 2023-06-04T20:00:26.167755+00:00 0:00:00.946995 391112 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T20:00:23.259188+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T19:00:00+00:00 PythonOperator 2023-06-04T20:00:03.431155+00:00 2023-06-04T20:00:04.339571+00:00 0:00:00.908416 391110 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T20:00:01.258002+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T18:00:00+00:00 TriggerDagRunOperator 2023-06-04T19:10:57.258341+00:00 2023-06-04T19:10:57.690219+00:00 0:00:00.431878 391097 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T19:10:55.218635+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T18:00:00+00:00 TriggerDagRunOperator 2023-06-04T19:10:57.181509+00:00 2023-06-04T19:10:57.633924+00:00 0:00:00.452415 391096 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T19:10:55.218665+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T18:00:00+00:00 EmrJobFlowSensor 2023-06-04T19:00:48.569580+00:00 2023-06-04T19:10:50.185648+00:00 0:10:01.616068 391089 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T19:00:46.401693+00:00 2 default_pool