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_booking-processing-job_v002 2023-03-29T19:00:00+00:00 TriggerDagRunOperator 2023-03-29T20:11:10.071820+00:00 2023-03-29T20:11:10.523933+00:00 0:00:00.452113 361107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T20:11:07.829082+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T19:00:00+00:00 EmrJobFlowSensor 2023-03-29T20:01:02.808393+00:00 2023-03-29T20:11:04.691203+00:00 0:10:01.882810 361100 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T20:01:00.390608+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T20:00:40.532551+00:00 2023-03-29T20:00:41.555575+00:00 0:00:01.023024 361098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T20:00:38.367954+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T19:00:00+00:00 PythonOperator 2023-03-29T20:00:19.259050+00:00 2023-03-29T20:00:23.349717+00:00 0:00:04.090667 361096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T20:00:16.390398+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T18:00:00+00:00 TriggerDagRunOperator 2023-03-29T19:11:01.496366+00:00 2023-03-29T19:11:02.020359+00:00 0:00:00.523993 361085 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T19:10:59.018386+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T18:00:00+00:00 TriggerDagRunOperator 2023-03-29T19:11:01.219079+00:00 2023-03-29T19:11:01.738465+00:00 0:00:00.519386 361084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T19:10:59.018426+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T18:00:00+00:00 EmrJobFlowSensor 2023-03-29T19:00:52.830644+00:00 2023-03-29T19:10:54.667095+00:00 0:10:01.836451 361077 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T19:00:50.294681+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T19:00:31.360389+00:00 2023-03-29T19:00:32.142075+00:00 0:00:00.781686 361075 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T19:00:28.307784+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T18:00:00+00:00 PythonOperator 2023-03-29T19:00:10.832859+00:00 2023-03-29T19:00:14.142601+00:00 0:00:03.309742 361073 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T19:00:08.215621+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T17:00:00+00:00 TriggerDagRunOperator 2023-03-29T18:16:10.928761+00:00 2023-03-29T18:16:11.443824+00:00 0:00:00.515063 361064 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T18:16:07.832688+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T17:00:00+00:00 TriggerDagRunOperator 2023-03-29T18:16:10.610263+00:00 2023-03-29T18:16:11.173380+00:00 0:00:00.563117 361063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T18:16:07.832743+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T17:00:00+00:00 EmrJobFlowSensor 2023-03-29T18:01:02.587653+00:00 2023-03-29T18:11:04.593455+00:00 0:10:02.005802 361056 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T18:00:59.426786+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T18:00:41.034107+00:00 2023-03-29T18:00:41.919685+00:00 0:00:00.885578 361054 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T18:00:37.418612+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T17:00:00+00:00 PythonOperator 2023-03-29T18:00:16.142128+00:00 2023-03-29T18:00:19.408036+00:00 0:00:03.265908 361052 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T18:00:13.428251+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T16:00:00+00:00 TriggerDagRunOperator 2023-03-29T17:29:46.362456+00:00 2023-03-29T17:29:46.834080+00:00 0:00:00.471624 361045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T17:29:43.978315+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T16:00:00+00:00 TriggerDagRunOperator 2023-03-29T17:29:46.346391+00:00 2023-03-29T17:29:46.827337+00:00 0:00:00.480946 361044 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T17:29:43.978287+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T16:00:00+00:00 EmrJobFlowSensor 2023-03-29T17:00:57.668844+00:00 2023-03-29T17:10:59.578598+00:00 0:10:01.909754 361037 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T17:00:55.225081+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T17:00:37.249487+00:00 2023-03-29T17:00:38.389008+00:00 0:00:01.139521 361035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T17:00:33.125831+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T16:00:00+00:00 PythonOperator 2023-03-29T17:00:15.495902+00:00 2023-03-29T17:00:18.879939+00:00 0:00:03.384037 361033 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T17:00:13.107601+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T15:00:00+00:00 TriggerDagRunOperator 2023-03-29T16:11:39.020972+00:00 2023-03-29T16:11:39.539131+00:00 0:00:00.518159 361023 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T16:11:36.345456+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T15:00:00+00:00 TriggerDagRunOperator 2023-03-29T16:11:38.719586+00:00 2023-03-29T16:11:39.174857+00:00 0:00:00.455271 361022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T16:11:36.345425+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T15:00:00+00:00 EmrJobFlowSensor 2023-03-29T16:01:17.156143+00:00 2023-03-29T16:11:18.977396+00:00 0:10:01.821253 361016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T16:01:14.832645+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T16:00:55.703200+00:00 2023-03-29T16:00:56.817720+00:00 0:00:01.114520 361014 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T16:00:52.810851+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T15:00:00+00:00 PythonOperator 2023-03-29T16:00:34.997583+00:00 2023-03-29T16:00:39.004599+00:00 0:00:04.007016 361012 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T16:00:32.784975+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T14:00:00+00:00 TriggerDagRunOperator 2023-03-29T15:37:24.690219+00:00 2023-03-29T15:37:25.169610+00:00 0:00:00.479391 361005 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T15:37:22.148335+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T14:00:00+00:00 TriggerDagRunOperator 2023-03-29T15:37:24.495874+00:00 2023-03-29T15:37:24.945214+00:00 0:00:00.449340 361004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T15:37:22.148363+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T14:00:00+00:00 EmrJobFlowSensor 2023-03-29T15:26:59.034825+00:00 2023-03-29T15:37:00.827125+00:00 0:10:01.792300 360999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T15:26:56.892120+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T15:26:37.060552+00:00 2023-03-29T15:26:37.885635+00:00 0:00:00.825083 360996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T15:26:34.873310+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T14:00:00+00:00 PythonOperator 2023-03-29T15:26:17.622642+00:00 2023-03-29T15:26:24.611390+00:00 0:00:06.988748 360993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T15:26:14.905478+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T13:00:00+00:00 TriggerDagRunOperator 2023-03-29T14:20:34.272041+00:00 2023-03-29T14:20:34.844548+00:00 0:00:00.572507 360985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T14:20:31.162238+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T13:00:00+00:00 TriggerDagRunOperator 2023-03-29T14:20:34.005900+00:00 2023-03-29T14:20:34.460798+00:00 0:00:00.454898 360984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T14:20:31.162211+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T13:00:00+00:00 EmrJobFlowSensor 2023-03-29T14:02:15.532323+00:00 2023-03-29T14:12:17.261338+00:00 0:10:01.729015 360978 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T14:02:13.129469+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T14:01:55.531684+00:00 2023-03-29T14:01:56.573992+00:00 0:00:01.042308 360976 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T14:01:53.073867+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T13:00:00+00:00 PythonOperator 2023-03-29T14:01:33.329060+00:00 2023-03-29T14:01:36.427888+00:00 0:00:03.098828 360974 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T14:01:31.062120+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T12:00:00+00:00 TriggerDagRunOperator 2023-03-29T13:11:15.342426+00:00 2023-03-29T13:11:15.804204+00:00 0:00:00.461778 360966 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T13:11:12.919561+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T12:00:00+00:00 TriggerDagRunOperator 2023-03-29T13:11:15.240495+00:00 2023-03-29T13:11:15.705009+00:00 0:00:00.464514 360965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T13:11:12.919533+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T12:00:00+00:00 EmrJobFlowSensor 2023-03-29T13:01:04.649473+00:00 2023-03-29T13:11:06.391531+00:00 0:10:01.742058 360959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T13:01:02.414582+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T13:00:44.617926+00:00 2023-03-29T13:00:45.641144+00:00 0:00:01.023218 360957 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T13:00:42.329730+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T12:00:00+00:00 PythonOperator 2023-03-29T13:00:22.465911+00:00 2023-03-29T13:00:26.531340+00:00 0:00:04.065429 360955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T13:00:20.285852+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T11:00:00+00:00 TriggerDagRunOperator 2023-03-29T12:11:11.658566+00:00 2023-03-29T12:11:12.130187+00:00 0:00:00.471621 360943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T12:11:09.012206+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T11:00:00+00:00 TriggerDagRunOperator 2023-03-29T12:11:11.407788+00:00 2023-03-29T12:11:11.882260+00:00 0:00:00.474472 360942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T12:11:09.012235+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T11:00:00+00:00 EmrJobFlowSensor 2023-03-29T12:00:53.824226+00:00 2023-03-29T12:10:55.696881+00:00 0:10:01.872655 360935 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T12:00:51.334286+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T12:00:32.249765+00:00 2023-03-29T12:00:33.442706+00:00 0:00:01.192941 360933 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T12:00:29.274180+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T11:00:00+00:00 PythonOperator 2023-03-29T12:00:10.165932+00:00 2023-03-29T12:00:13.399935+00:00 0:00:03.234003 360931 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T12:00:07.248560+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T10:00:00+00:00 TriggerDagRunOperator 2023-03-29T11:11:29.441008+00:00 2023-03-29T11:11:30.208408+00:00 0:00:00.767400 360924 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T11:11:26.573129+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T10:00:00+00:00 TriggerDagRunOperator 2023-03-29T11:11:29.098173+00:00 2023-03-29T11:11:29.557587+00:00 0:00:00.459414 360923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T11:11:26.573159+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T10:00:00+00:00 EmrJobFlowSensor 2023-03-29T11:01:04.784423+00:00 2023-03-29T11:11:06.739429+00:00 0:10:01.955006 360917 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T11:01:02.474755+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T11:00:42.769738+00:00 2023-03-29T11:00:43.706649+00:00 0:00:00.936911 360915 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T11:00:40.506658+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T10:00:00+00:00 PythonOperator 2023-03-29T11:00:22.777292+00:00 2023-03-29T11:00:25.994403+00:00 0:00:03.217111 360913 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T11:00:20.437560+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T09:00:00+00:00 TriggerDagRunOperator 2023-03-29T10:32:36.705442+00:00 2023-03-29T10:32:37.231181+00:00 0:00:00.525739 360905 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T10:32:33.782195+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T09:00:00+00:00 TriggerDagRunOperator 2023-03-29T10:32:36.552380+00:00 2023-03-29T10:32:37.026436+00:00 0:00:00.474056 360904 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T10:32:33.782227+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T09:00:00+00:00 EmrJobFlowSensor 2023-03-29T10:20:12.171978+00:00 2023-03-29T10:30:13.862753+00:00 0:10:01.690775 360899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T10:20:09.988662+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T10:19:52.239119+00:00 2023-03-29T10:19:53.099745+00:00 0:00:00.860626 360896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T10:19:49.971526+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T09:00:00+00:00 PythonOperator 2023-03-29T10:19:30.720624+00:00 2023-03-29T10:19:34.874308+00:00 0:00:04.153684 360893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T10:19:27.825426+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T08:00:00+00:00 TriggerDagRunOperator 2023-03-29T09:10:56.308945+00:00 2023-03-29T09:10:56.788000+00:00 0:00:00.479055 360883 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T09:10:54.073510+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T08:00:00+00:00 TriggerDagRunOperator 2023-03-29T09:10:56.265404+00:00 2023-03-29T09:10:56.737089+00:00 0:00:00.471685 360882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T09:10:54.073478+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T08:00:00+00:00 EmrJobFlowSensor 2023-03-29T09:00:49.585061+00:00 2023-03-29T09:10:51.273655+00:00 0:10:01.688594 360875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T09:00:47.412936+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T09:00:29.537079+00:00 2023-03-29T09:00:30.436496+00:00 0:00:00.899417 360873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T09:00:27.397089+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T08:00:00+00:00 PythonOperator 2023-03-29T09:00:07.855751+00:00 2023-03-29T09:00:11.231765+00:00 0:00:03.376014 360871 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T09:00:05.379068+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T07:00:00+00:00 TriggerDagRunOperator 2023-03-29T08:18:10.528123+00:00 2023-03-29T08:18:11.100218+00:00 0:00:00.572095 360864 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T08:18:07.772397+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T07:00:00+00:00 TriggerDagRunOperator 2023-03-29T08:18:10.377120+00:00 2023-03-29T08:18:10.832548+00:00 0:00:00.455428 360863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T08:18:07.772424+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T07:00:00+00:00 EmrJobFlowSensor 2023-03-29T08:00:46.840846+00:00 2023-03-29T08:10:48.574358+00:00 0:10:01.733512 360855 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T08:00:44.644052+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T08:00:26.946621+00:00 2023-03-29T08:00:27.811539+00:00 0:00:00.864918 360853 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T08:00:24.608295+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T07:00:00+00:00 PythonOperator 2023-03-29T08:00:05.041584+00:00 2023-03-29T08:00:08.473625+00:00 0:00:03.432041 360851 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T08:00:02.585089+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T06:00:00+00:00 TriggerDagRunOperator 2023-03-29T07:14:36.351670+00:00 2023-03-29T07:14:36.846159+00:00 0:00:00.494489 360843 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T07:14:34.025804+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T06:00:00+00:00 TriggerDagRunOperator 2023-03-29T07:14:36.309806+00:00 2023-03-29T07:14:36.785029+00:00 0:00:00.475223 360842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T07:14:34.025833+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T06:00:00+00:00 EmrJobFlowSensor 2023-03-29T07:04:18.075533+00:00 2023-03-29T07:14:19.769642+00:00 0:10:01.694109 360836 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T07:04:15.803966+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T07:03:58.040988+00:00 2023-03-29T07:03:59.325459+00:00 0:00:01.284471 360834 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T07:03:53.729901+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T06:00:00+00:00 PythonOperator 2023-03-29T07:03:35.963006+00:00 2023-03-29T07:03:40.077387+00:00 0:00:04.114381 360832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T07:03:33.702887+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T05:00:00+00:00 TriggerDagRunOperator 2023-03-29T06:12:40.487263+00:00 2023-03-29T06:12:41.032677+00:00 0:00:00.545414 360821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T06:12:37.387841+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T05:00:00+00:00 TriggerDagRunOperator 2023-03-29T06:12:40.283965+00:00 2023-03-29T06:12:40.762777+00:00 0:00:00.478812 360820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T06:12:37.387791+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T05:00:00+00:00 EmrJobFlowSensor 2023-03-29T06:00:49.583020+00:00 2023-03-29T06:11:51.579705+00:00 0:11:01.996685 360812 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T06:00:44.872200+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T06:00:25.096172+00:00 2023-03-29T06:00:26.066397+00:00 0:00:00.970225 360810 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T06:00:22.844693+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T05:00:00+00:00 PythonOperator 2023-03-29T06:00:03.351528+00:00 2023-03-29T06:00:07.483725+00:00 0:00:04.132197 360808 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T06:00:00.834331+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T04:00:00+00:00 TriggerDagRunOperator 2023-03-29T05:23:58.292609+00:00 2023-03-29T05:23:58.761334+00:00 0:00:00.468725 360801 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T05:23:55.328609+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T04:00:00+00:00 TriggerDagRunOperator 2023-03-29T05:23:58.106912+00:00 2023-03-29T05:23:58.573452+00:00 0:00:00.466540 360800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T05:23:55.328656+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T04:00:00+00:00 EmrJobFlowSensor 2023-03-29T05:11:37.023469+00:00 2023-03-29T05:21:38.834115+00:00 0:10:01.810646 360797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T05:11:34.732480+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T05:11:17.116326+00:00 2023-03-29T05:11:17.952381+00:00 0:00:00.836055 360794 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T05:11:14.700690+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T04:00:00+00:00 PythonOperator 2023-03-29T05:10:55.319088+00:00 2023-03-29T05:10:59.153352+00:00 0:00:03.834264 360791 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T05:10:52.681283+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T03:00:00+00:00 TriggerDagRunOperator 2023-03-29T04:15:04.085136+00:00 2023-03-29T04:15:04.598171+00:00 0:00:00.513035 360781 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T04:15:01.772447+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T03:00:00+00:00 TriggerDagRunOperator 2023-03-29T04:15:04.060207+00:00 2023-03-29T04:15:04.557814+00:00 0:00:00.497607 360780 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T04:15:01.772484+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T03:00:00+00:00 EmrJobFlowSensor 2023-03-29T04:00:48.062596+00:00 2023-03-29T04:10:49.798803+00:00 0:10:01.736207 360775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T04:00:45.841330+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T04:00:26.569014+00:00 2023-03-29T04:00:27.434985+00:00 0:00:00.865971 360773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T04:00:23.790527+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T03:00:00+00:00 PythonOperator 2023-03-29T04:00:06.418515+00:00 2023-03-29T04:00:10.714944+00:00 0:00:04.296429 360771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T04:00:03.738478+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T02:00:00+00:00 TriggerDagRunOperator 2023-03-29T03:14:44.565339+00:00 2023-03-29T03:14:45.243844+00:00 0:00:00.678505 360761 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T03:14:42.053960+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T02:00:00+00:00 TriggerDagRunOperator 2023-03-29T03:14:44.382869+00:00 2023-03-29T03:14:44.823675+00:00 0:00:00.440806 360760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T03:14:42.053931+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T02:00:00+00:00 EmrJobFlowSensor 2023-03-29T03:04:23.051217+00:00 2023-03-29T03:14:24.877416+00:00 0:10:01.826199 360753 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T03:04:20.636712+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T03:04:00.745260+00:00 2023-03-29T03:04:01.675188+00:00 0:00:00.929928 360751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T03:03:58.578864+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T02:00:00+00:00 PythonOperator 2023-03-29T03:03:41.098744+00:00 2023-03-29T03:03:44.326888+00:00 0:00:03.228144 360749 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T03:03:38.555379+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T01:00:00+00:00 TriggerDagRunOperator 2023-03-29T02:28:03.742610+00:00 2023-03-29T02:28:04.313166+00:00 0:00:00.570556 360741 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T02:28:00.446273+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T01:00:00+00:00 TriggerDagRunOperator 2023-03-29T02:28:03.300143+00:00 2023-03-29T02:28:03.787254+00:00 0:00:00.487111 360740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T02:28:00.446301+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T01:00:00+00:00 EmrJobFlowSensor 2023-03-29T02:01:54.585109+00:00 2023-03-29T02:11:56.672906+00:00 0:10:02.087797 360733 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T02:01:52.300029+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T02:01:32.582066+00:00 2023-03-29T02:01:33.508714+00:00 0:00:00.926648 360731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T02:01:30.269600+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T01:00:00+00:00 PythonOperator 2023-03-29T02:01:13.042188+00:00 2023-03-29T02:01:16.588354+00:00 0:00:03.546166 360729 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T02:01:10.303123+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T00:00:00+00:00 TriggerDagRunOperator 2023-03-29T01:29:25.253443+00:00 2023-03-29T01:29:25.971144+00:00 0:00:00.717701 360715 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T01:29:22.314714+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T00:00:00+00:00 TriggerDagRunOperator 2023-03-29T01:29:25.095965+00:00 2023-03-29T01:29:25.687002+00:00 0:00:00.591037 360714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T01:29:22.314670+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T00:00:00+00:00 EmrJobFlowSensor 2023-03-29T01:19:07.523345+00:00 2023-03-29T01:29:09.362643+00:00 0:10:01.839298 360710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T01:19:05.095829+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T01:18:45.387706+00:00 2023-03-29T01:18:46.206960+00:00 0:00:00.819254 360707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T01:18:43.030261+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T00:00:00+00:00 PythonOperator 2023-03-29T01:18:23.305503+00:00 2023-03-29T01:18:27.902859+00:00 0:00:04.597356 360704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T01:18:21.021053+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T23:00:00+00:00 TriggerDagRunOperator 2023-03-29T00:15:37.569172+00:00 2023-03-29T00:15:38.011584+00:00 0:00:00.442412 360696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T00:15:34.591262+00:00 2 default_pool