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 trigger_dagrun_campaign-history-job_v002 2023-04-12T04:00:00+00:00 TriggerDagRunOperator 2023-04-27T12:06:20.403619+00:00 2023-04-27T12:06:20.766899+00:00 0:00:00.363280 368766 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-27T12:06:18.120909+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-27T11:00:00+00:00 EmrCreateJobFlowOperator 2023-04-27T12:03:53.603384+00:00 2023-04-27T12:03:54.367146+00:00 0:00:00.763762 368761 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-27T12:03:47.901564+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-27T11:00:00+00:00 PythonOperator 2023-04-27T12:03:35.111455+00:00 2023-04-27T12:03:36.218326+00:00 0:00:01.106871 368753 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-27T12:03:27.886303+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-27T10:00:00+00:00 EmrCreateJobFlowOperator 2023-04-27T11:56:25.200579+00:00 2023-04-27T11:56:26.094067+00:00 0:00:00.893488 368738 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-27T11:56:22.659555+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-27T10:00:00+00:00 PythonOperator 2023-04-27T11:56:05.515519+00:00 2023-04-27T11:56:06.587281+00:00 0:00:01.071762 368730 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-27T11:56:00.646171+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-12T05:00:00+00:00 EmrCreateJobFlowOperator 2023-04-27T11:56:05.510708+00:00 2023-04-27T11:56:06.525382+00:00 0:00:01.014674 368729 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-27T11:56:00.646145+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-12T04:00:00+00:00 EmrJobFlowSensor 2023-04-27T11:56:03.051708+00:00 2023-04-27T12:06:04.963396+00:00 0:10:01.911688 368728 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-27T11:56:00.646092+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-12T04:00:00+00:00 EmrCreateJobFlowOperator 2023-04-27T11:55:43.249687+00:00 2023-04-27T11:55:44.094870+00:00 0:00:00.845183 368727 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-27T11:55:40.723426+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-12T05:00:00+00:00 PythonOperator 2023-04-27T11:55:43.123703+00:00 2023-04-27T11:55:43.979405+00:00 0:00:00.855702 368726 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-27T11:55:40.723469+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-12T04:00:00+00:00 PythonOperator 2023-04-27T11:55:20.820139+00:00 2023-04-27T11:55:21.606978+00:00 0:00:00.786839 368723 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-27T11:55:18.520663+00:00 3 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-08T17:00:00+00:00 TriggerDagRunOperator 2023-04-12T06:20:50.865329+00:00 2023-04-12T06:20:55.872954+00:00 0:00:05.007625 366076 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-12T06:18:03.789640+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-08T17:00:00+00:00 EmrJobFlowSensor 2023-04-08T18:16:47.803736+00:00 2023-04-08T18:26:49.554768+00:00 0:10:01.751032 365981 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-08T18:16:44.851084+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-08T17:00:00+00:00 EmrCreateJobFlowOperator 2023-04-08T18:16:24.997554+00:00 2023-04-08T18:16:25.828109+00:00 0:00:00.830555 365978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-08T18:16:22.840085+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-08T17:00:00+00:00 PythonOperator 2023-04-08T18:16:05.510263+00:00 2023-04-08T18:16:10.992172+00:00 0:00:05.481909 365975 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-08T18:16:00.778493+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-08T16:00:00+00:00 TriggerDagRunOperator 2023-04-08T17:17:20.983815+00:00 2023-04-08T17:17:21.473432+00:00 0:00:00.489617 365964 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T17:17:18.203464+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-08T16:00:00+00:00 TriggerDagRunOperator 2023-04-08T17:17:20.727776+00:00 2023-04-08T17:17:21.198286+00:00 0:00:00.470510 365963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T17:17:18.203435+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-08T16:00:00+00:00 EmrJobFlowSensor 2023-04-08T17:07:03.943778+00:00 2023-04-08T17:17:05.723251+00:00 0:10:01.779473 365960 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-08T17:07:00.897073+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-08T16:00:00+00:00 EmrCreateJobFlowOperator 2023-04-08T17:06:41.092304+00:00 2023-04-08T17:06:41.994928+00:00 0:00:00.902624 365957 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-08T17:06:38.764088+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-08T16:00:00+00:00 PythonOperator 2023-04-08T17:06:18.916617+00:00 2023-04-08T17:06:23.139024+00:00 0:00:04.222407 365954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-08T17:06:16.747384+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-08T15:00:00+00:00 TriggerDagRunOperator 2023-04-08T16:22:32.105646+00:00 2023-04-08T16:22:32.643660+00:00 0:00:00.538014 365947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T16:22:29.217165+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-08T15:00:00+00:00 TriggerDagRunOperator 2023-04-08T16:22:31.805152+00:00 2023-04-08T16:22:32.269970+00:00 0:00:00.464818 365946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T16:22:29.217201+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-08T15:00:00+00:00 EmrJobFlowSensor 2023-04-08T16:04:23.142514+00:00 2023-04-08T16:14:24.878971+00:00 0:10:01.736457 365940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-08T16:04:20.949440+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-08T15:00:00+00:00 EmrCreateJobFlowOperator 2023-04-08T16:04:01.176311+00:00 2023-04-08T16:04:02.308142+00:00 0:00:01.131831 365938 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-08T16:03:58.940016+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-08T15:00:00+00:00 PythonOperator 2023-04-08T16:03:41.050901+00:00 2023-04-08T16:03:45.165787+00:00 0:00:04.114886 365936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-08T16:03:38.911228+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-08T14:00:00+00:00 TriggerDagRunOperator 2023-04-08T15:15:00.540120+00:00 2023-04-08T15:15:01.078013+00:00 0:00:00.537893 365928 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T15:14:57.360356+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-08T14:00:00+00:00 TriggerDagRunOperator 2023-04-08T15:15:00.385748+00:00 2023-04-08T15:15:00.858882+00:00 0:00:00.473134 365927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T15:14:57.360311+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-08T13:00:00+00:00 TriggerDagRunOperator 2023-04-08T15:03:39.703883+00:00 2023-04-08T15:03:40.267592+00:00 0:00:00.563709 365919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T15:03:35.312232+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-08T13:00:00+00:00 TriggerDagRunOperator 2023-04-08T15:03:39.642572+00:00 2023-04-08T15:03:40.188432+00:00 0:00:00.545860 365918 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T15:03:35.312197+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-08T14:00:00+00:00 EmrJobFlowSensor 2023-04-08T15:03:38.037346+00:00 2023-04-08T15:10:39.481419+00:00 0:07:01.444073 365917 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-08T15:03:35.312247+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-08T14:00:00+00:00 EmrCreateJobFlowOperator 2023-04-08T15:00:41.177316+00:00 2023-04-08T15:00:41.986873+00:00 0:00:00.809557 365914 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-08T15:00:38.983401+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-08T14:00:00+00:00 PythonOperator 2023-04-08T15:00:19.240096+00:00 2023-04-08T15:00:23.013065+00:00 0:00:03.772969 365912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-08T15:00:16.956985+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-08T13:00:00+00:00 EmrJobFlowSensor 2023-04-08T14:53:31.552173+00:00 2023-04-08T15:03:33.322053+00:00 0:10:01.769880 365906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-08T14:53:29.340840+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-08T13:00:00+00:00 EmrCreateJobFlowOperator 2023-04-08T14:53:09.475809+00:00 2023-04-08T14:53:10.274281+00:00 0:00:00.798472 365903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-08T14:53:07.316552+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-08T13:00:00+00:00 PythonOperator 2023-04-08T14:52:50.149650+00:00 2023-04-08T14:52:53.775566+00:00 0:00:03.625916 365900 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-08T14:52:47.302556+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-08T12:00:00+00:00 TriggerDagRunOperator 2023-04-08T13:20:49.276617+00:00 2023-04-08T13:20:49.785345+00:00 0:00:00.508728 365893 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T13:20:46.698376+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-08T12:00:00+00:00 TriggerDagRunOperator 2023-04-08T13:20:49.019962+00:00 2023-04-08T13:20:49.460469+00:00 0:00:00.440507 365892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T13:20:46.698348+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-08T12:00:00+00:00 EmrJobFlowSensor 2023-04-08T13:10:40.635230+00:00 2023-04-08T13:20:42.841599+00:00 0:10:02.206369 365887 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-08T13:10:38.341132+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-08T12:00:00+00:00 EmrCreateJobFlowOperator 2023-04-08T13:10:20.608040+00:00 2023-04-08T13:10:21.524449+00:00 0:00:00.916409 365884 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-08T13:10:18.325241+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-08T12:00:00+00:00 PythonOperator 2023-04-08T13:09:59.987116+00:00 2023-04-08T13:10:09.213619+00:00 0:00:09.226503 365881 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-08T13:09:56.305830+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-08T11:00:00+00:00 TriggerDagRunOperator 2023-04-08T12:19:40.381242+00:00 2023-04-08T12:19:40.834234+00:00 0:00:00.452992 365873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T12:19:37.227496+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-08T11:00:00+00:00 TriggerDagRunOperator 2023-04-08T12:19:40.203440+00:00 2023-04-08T12:19:40.679348+00:00 0:00:00.475908 365872 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T12:19:37.227457+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-08T11:00:00+00:00 EmrJobFlowSensor 2023-04-08T12:00:51.076049+00:00 2023-04-08T12:10:52.903893+00:00 0:10:01.827844 365865 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-08T12:00:48.884019+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-08T11:00:00+00:00 EmrCreateJobFlowOperator 2023-04-08T12:00:29.261556+00:00 2023-04-08T12:00:30.449770+00:00 0:00:01.188214 365863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-08T12:00:26.868192+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-08T11:00:00+00:00 PythonOperator 2023-04-08T12:00:09.391301+00:00 2023-04-08T12:00:12.603360+00:00 0:00:03.212059 365861 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-08T12:00:06.843003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-08T10:00:00+00:00 TriggerDagRunOperator 2023-04-08T11:20:13.056321+00:00 2023-04-08T11:20:13.542679+00:00 0:00:00.486358 365854 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T11:20:10.434785+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-08T10:00:00+00:00 TriggerDagRunOperator 2023-04-08T11:20:13.009180+00:00 2023-04-08T11:20:13.464401+00:00 0:00:00.455221 365853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T11:20:10.434755+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-08T10:00:00+00:00 EmrJobFlowSensor 2023-04-08T11:07:56.146904+00:00 2023-04-08T11:17:57.868520+00:00 0:10:01.721616 365849 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-08T11:07:53.897288+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-08T10:00:00+00:00 EmrCreateJobFlowOperator 2023-04-08T11:07:34.109799+00:00 2023-04-08T11:07:35.106773+00:00 0:00:00.996974 365846 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-08T11:07:31.863023+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-08T10:00:00+00:00 PythonOperator 2023-04-08T11:07:12.079179+00:00 2023-04-08T11:07:16.222018+00:00 0:00:04.142839 365843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-08T11:07:09.841423+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-08T09:00:00+00:00 TriggerDagRunOperator 2023-04-08T10:37:01.460848+00:00 2023-04-08T10:37:01.926065+00:00 0:00:00.465217 365837 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T10:36:58.130447+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-08T09:00:00+00:00 TriggerDagRunOperator 2023-04-08T10:37:01.258240+00:00 2023-04-08T10:37:01.717354+00:00 0:00:00.459114 365836 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T10:36:58.130396+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-08T09:00:00+00:00 EmrJobFlowSensor 2023-04-08T10:12:45.235198+00:00 2023-04-08T10:22:47.651496+00:00 0:10:02.416298 365832 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-08T10:12:42.682139+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-08T09:00:00+00:00 EmrCreateJobFlowOperator 2023-04-08T10:12:25.336733+00:00 2023-04-08T10:12:26.793405+00:00 0:00:01.456672 365829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-08T10:12:22.663608+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-08T09:00:00+00:00 PythonOperator 2023-04-08T10:12:05.038950+00:00 2023-04-08T10:12:10.148978+00:00 0:00:05.110028 365826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-08T10:12:00.643608+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-08T08:00:00+00:00 TriggerDagRunOperator 2023-04-08T09:11:03.034303+00:00 2023-04-08T09:11:03.529958+00:00 0:00:00.495655 365818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T09:11:00.309014+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-08T08:00:00+00:00 TriggerDagRunOperator 2023-04-08T09:11:02.855745+00:00 2023-04-08T09:11:03.350140+00:00 0:00:00.494395 365817 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T09:11:00.309051+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-08T08:00:00+00:00 EmrJobFlowSensor 2023-04-08T09:00:52.904976+00:00 2023-04-08T09:10:54.823606+00:00 0:10:01.918630 365811 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-08T09:00:50.593748+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-08T08:00:00+00:00 EmrCreateJobFlowOperator 2023-04-08T09:00:33.315943+00:00 2023-04-08T09:00:34.212211+00:00 0:00:00.896268 365809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-08T09:00:30.699599+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-08T08:00:00+00:00 PythonOperator 2023-04-08T09:00:10.759039+00:00 2023-04-08T09:00:14.780729+00:00 0:00:04.021690 365807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-08T09:00:08.524278+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-08T07:00:00+00:00 TriggerDagRunOperator 2023-04-08T08:11:20.961484+00:00 2023-04-08T08:11:21.485350+00:00 0:00:00.523866 365797 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T08:11:18.511132+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-08T07:00:00+00:00 TriggerDagRunOperator 2023-04-08T08:11:20.739733+00:00 2023-04-08T08:11:21.203232+00:00 0:00:00.463499 365796 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T08:11:18.511165+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-08T07:00:00+00:00 EmrJobFlowSensor 2023-04-08T08:01:07.777432+00:00 2023-04-08T08:11:09.661942+00:00 0:10:01.884510 365790 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-08T08:01:05.248765+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-08T07:00:00+00:00 EmrCreateJobFlowOperator 2023-04-08T08:00:47.694315+00:00 2023-04-08T08:00:49.060891+00:00 0:00:01.366576 365788 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-08T08:00:43.302955+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-08T07:00:00+00:00 PythonOperator 2023-04-08T08:00:25.029039+00:00 2023-04-08T08:00:29.139178+00:00 0:00:04.110139 365786 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-08T08:00:21.217678+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-08T06:00:00+00:00 TriggerDagRunOperator 2023-04-08T07:13:54.554556+00:00 2023-04-08T07:13:55.251106+00:00 0:00:00.696550 365778 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T07:13:51.266216+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-08T06:00:00+00:00 TriggerDagRunOperator 2023-04-08T07:13:54.063042+00:00 2023-04-08T07:13:54.790358+00:00 0:00:00.727316 365777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T07:13:51.266255+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-08T06:00:00+00:00 EmrJobFlowSensor 2023-04-08T07:01:07.134682+00:00 2023-04-08T07:11:08.900707+00:00 0:10:01.766025 365771 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-08T07:01:04.828531+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-08T06:00:00+00:00 EmrCreateJobFlowOperator 2023-04-08T07:00:45.388348+00:00 2023-04-08T07:00:46.260149+00:00 0:00:00.871801 365769 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-08T07:00:42.773880+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-08T06:00:00+00:00 PythonOperator 2023-04-08T07:00:25.796665+00:00 2023-04-08T07:00:29.505971+00:00 0:00:03.709306 365767 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-08T07:00:22.753576+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-08T05:00:00+00:00 TriggerDagRunOperator 2023-04-08T06:13:45.787353+00:00 2023-04-08T06:13:46.247097+00:00 0:00:00.459744 365757 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T06:13:43.118192+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-08T05:00:00+00:00 TriggerDagRunOperator 2023-04-08T06:13:45.768032+00:00 2023-04-08T06:13:46.314246+00:00 0:00:00.546214 365756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T06:13:43.118220+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-08T05:00:00+00:00 EmrJobFlowSensor 2023-04-08T06:03:24.637647+00:00 2023-04-08T06:13:26.413937+00:00 0:10:01.776290 365749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-08T06:03:22.423581+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-08T05:00:00+00:00 EmrCreateJobFlowOperator 2023-04-08T06:03:02.873939+00:00 2023-04-08T06:03:03.926591+00:00 0:00:01.052652 365747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-08T06:03:00.358660+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-08T05:00:00+00:00 PythonOperator 2023-04-08T06:02:43.283915+00:00 2023-04-08T06:02:47.095235+00:00 0:00:03.811320 365745 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-08T06:02:40.341660+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-08T04:00:00+00:00 TriggerDagRunOperator 2023-04-08T05:18:22.484141+00:00 2023-04-08T05:18:22.986512+00:00 0:00:00.502371 365736 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T05:18:19.932545+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-08T04:00:00+00:00 TriggerDagRunOperator 2023-04-08T05:18:22.309300+00:00 2023-04-08T05:18:22.776613+00:00 0:00:00.467313 365735 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T05:18:19.932573+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-08T04:00:00+00:00 EmrJobFlowSensor 2023-04-08T05:06:57.448372+00:00 2023-04-08T05:17:59.543381+00:00 0:11:02.095009 365731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-08T05:06:55.115290+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-08T04:00:00+00:00 EmrCreateJobFlowOperator 2023-04-08T05:06:38.141686+00:00 2023-04-08T05:06:39.172254+00:00 0:00:01.030568 365729 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-08T05:06:33.072781+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-08T04:00:00+00:00 PythonOperator 2023-04-08T05:06:15.374136+00:00 2023-04-08T05:06:19.423693+00:00 0:00:04.049557 365725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-08T05:06:13.060902+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-08T03:00:00+00:00 TriggerDagRunOperator 2023-04-08T04:21:45.127513+00:00 2023-04-08T04:21:45.705632+00:00 0:00:00.578119 365717 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T04:21:42.629967+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-08T03:00:00+00:00 TriggerDagRunOperator 2023-04-08T04:21:44.913842+00:00 2023-04-08T04:21:45.529258+00:00 0:00:00.615416 365716 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T04:21:42.629994+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-08T03:00:00+00:00 EmrJobFlowSensor 2023-04-08T04:11:21.859893+00:00 2023-04-08T04:21:23.748830+00:00 0:10:01.888937 365711 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-08T04:11:19.633237+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-08T03:00:00+00:00 EmrCreateJobFlowOperator 2023-04-08T04:11:00.278510+00:00 2023-04-08T04:11:01.265459+00:00 0:00:00.986949 365708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-08T04:10:57.570915+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-08T03:00:00+00:00 PythonOperator 2023-04-08T04:10:40.591014+00:00 2023-04-08T04:10:44.320869+00:00 0:00:03.729855 365705 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-08T04:10:37.563788+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-08T02:00:00+00:00 TriggerDagRunOperator 2023-04-08T03:14:38.078133+00:00 2023-04-08T03:14:38.570124+00:00 0:00:00.491991 365693 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T03:14:35.877367+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-08T02:00:00+00:00 TriggerDagRunOperator 2023-04-08T03:14:38.060283+00:00 2023-04-08T03:14:38.523448+00:00 0:00:00.463165 365692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T03:14:35.877330+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-08T02:00:00+00:00 EmrJobFlowSensor 2023-04-08T03:00:49.984802+00:00 2023-04-08T03:10:51.731009+00:00 0:10:01.746207 365687 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-08T03:00:47.681728+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-08T02:00:00+00:00 EmrCreateJobFlowOperator 2023-04-08T03:00:29.761187+00:00 2023-04-08T03:00:30.659865+00:00 0:00:00.898678 365685 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-08T03:00:27.540497+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-08T02:00:00+00:00 PythonOperator 2023-04-08T03:00:07.901218+00:00 2023-04-08T03:00:11.332892+00:00 0:00:03.431674 365683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-08T03:00:05.495639+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-08T01:00:00+00:00 TriggerDagRunOperator 2023-04-08T02:12:04.493819+00:00 2023-04-08T02:12:04.958182+00:00 0:00:00.464363 365676 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T02:12:02.173469+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-08T01:00:00+00:00 TriggerDagRunOperator 2023-04-08T02:12:04.408885+00:00 2023-04-08T02:12:04.881660+00:00 0:00:00.472775 365675 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T02:12:02.173433+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-08T01:00:00+00:00 EmrJobFlowSensor 2023-04-08T02:00:53.853443+00:00 2023-04-08T02:11:55.855070+00:00 0:11:02.001627 365668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-08T02:00:51.538453+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-08T01:00:00+00:00 EmrCreateJobFlowOperator 2023-04-08T02:00:31.810731+00:00 2023-04-08T02:00:33.093446+00:00 0:00:01.282715 365666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-08T02:00:29.496632+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-08T01:00:00+00:00 PythonOperator 2023-04-08T02:00:12.167035+00:00 2023-04-08T02:00:15.799980+00:00 0:00:03.632945 365665 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-08T02:00:09.480014+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-08T00:00:00+00:00 TriggerDagRunOperator 2023-04-08T01:12:46.277973+00:00 2023-04-08T01:12:46.758205+00:00 0:00:00.480232 365650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T01:12:43.705764+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-08T00:00:00+00:00 TriggerDagRunOperator 2023-04-08T01:12:46.157737+00:00 2023-04-08T01:12:46.692554+00:00 0:00:00.534817 365649 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T01:12:43.705794+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-08T00:00:00+00:00 EmrJobFlowSensor 2023-04-08T01:02:27.391066+00:00 2023-04-08T01:12:29.063918+00:00 0:10:01.672852 365642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-08T01:02:25.123609+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-08T00:00:00+00:00 EmrCreateJobFlowOperator 2023-04-08T01:02:05.412470+00:00 2023-04-08T01:02:06.287603+00:00 0:00:00.875133 365640 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-08T01:02:03.078199+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-08T00:00:00+00:00 PythonOperator 2023-04-08T01:01:43.791850+00:00 2023-04-08T01:01:47.279934+00:00 0:00:03.488084 365638 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-08T01:01:41.058285+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T23:00:00+00:00 TriggerDagRunOperator 2023-04-08T00:20:24.189527+00:00 2023-04-08T00:20:24.682270+00:00 0:00:00.492743 365630 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T00:20:21.196846+00:00 2 default_pool