Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T15:00:41.809515+00:00 2023-05-31T15:00:42.988549+00:00 0:00:01.179034 388910 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T15:00:39.706858+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T14:00:00+00:00 PythonOperator 2023-05-31T15:00:21.905977+00:00 2023-05-31T15:00:22.848102+00:00 0:00:00.942125 388908 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T15:00:19.694300+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T13:00:00+00:00 TriggerDagRunOperator 2023-05-31T14:15:41.112745+00:00 2023-05-31T14:15:41.783443+00:00 0:00:00.670698 388895 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T14:15:38.221578+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T13:00:00+00:00 TriggerDagRunOperator 2023-05-31T14:15:40.722119+00:00 2023-05-31T14:15:41.215186+00:00 0:00:00.493067 388894 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T14:15:38.221539+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T13:00:00+00:00 EmrJobFlowSensor 2023-05-31T14:01:05.858181+00:00 2023-05-31T14:11:07.711637+00:00 0:10:01.853456 388891 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T14:01:03.789303+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T14:00:45.819135+00:00 2023-05-31T14:00:46.684931+00:00 0:00:00.865796 388889 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T14:00:43.760883+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T13:00:00+00:00 PythonOperator 2023-05-31T14:00:23.859267+00:00 2023-05-31T14:00:24.839101+00:00 0:00:00.979834 388887 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T14:00:21.740673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T12:00:00+00:00 TriggerDagRunOperator 2023-05-31T13:23:04.623917+00:00 2023-05-31T13:23:05.087557+00:00 0:00:00.463640 388879 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T13:23:02.316422+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T12:00:00+00:00 TriggerDagRunOperator 2023-05-31T13:23:04.570073+00:00 2023-05-31T13:23:05.048520+00:00 0:00:00.478447 388878 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T13:23:02.316394+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T12:00:00+00:00 EmrJobFlowSensor 2023-05-31T13:00:59.452315+00:00 2023-05-31T13:11:01.213349+00:00 0:10:01.761034 388870 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T13:00:57.332363+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T13:00:40.220284+00:00 2023-05-31T13:00:41.112225+00:00 0:00:00.891941 388869 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T13:00:37.313906+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T12:00:00+00:00 PythonOperator 2023-05-31T13:00:17.385158+00:00 2023-05-31T13:00:18.292381+00:00 0:00:00.907223 388867 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T13:00:15.257870+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T11:00:00+00:00 TriggerDagRunOperator 2023-05-31T12:27:56.025741+00:00 2023-05-31T12:27:56.476716+00:00 0:00:00.450975 388859 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T12:27:53.729200+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T11:00:00+00:00 TriggerDagRunOperator 2023-05-31T12:27:55.976737+00:00 2023-05-31T12:27:56.444541+00:00 0:00:00.467804 388858 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T12:27:53.729229+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T11:00:00+00:00 EmrJobFlowSensor 2023-05-31T12:01:05.862950+00:00 2023-05-31T12:11:07.752005+00:00 0:10:01.889055 388850 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T12:01:03.799290+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T12:00:43.877787+00:00 2023-05-31T12:00:45.149054+00:00 0:00:01.271267 388848 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T12:00:41.777643+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T11:00:00+00:00 PythonOperator 2023-05-31T12:00:24.075911+00:00 2023-05-31T12:00:24.998524+00:00 0:00:00.922613 388846 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T12:00:21.758601+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T10:00:00+00:00 TriggerDagRunOperator 2023-05-31T11:11:24.764079+00:00 2023-05-31T11:11:25.292191+00:00 0:00:00.528112 388838 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T11:11:22.109447+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T10:00:00+00:00 TriggerDagRunOperator 2023-05-31T11:11:24.722448+00:00 2023-05-31T11:11:25.248149+00:00 0:00:00.525701 388837 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T11:11:22.109419+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T10:00:00+00:00 EmrJobFlowSensor 2023-05-31T11:00:59.988147+00:00 2023-05-31T11:11:01.896141+00:00 0:10:01.907994 388830 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T11:00:57.941274+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T11:00:38.174694+00:00 2023-05-31T11:00:39.127156+00:00 0:00:00.952462 388828 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T11:00:35.988966+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T10:00:00+00:00 PythonOperator 2023-05-31T11:00:18.070770+00:00 2023-05-31T11:00:19.000396+00:00 0:00:00.929626 388826 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T11:00:15.883551+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T09:00:00+00:00 TriggerDagRunOperator 2023-05-31T10:12:08.950379+00:00 2023-05-31T10:12:09.397771+00:00 0:00:00.447392 388815 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T10:12:06.487730+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T09:00:00+00:00 TriggerDagRunOperator 2023-05-31T10:12:08.796698+00:00 2023-05-31T10:12:09.257208+00:00 0:00:00.460510 388814 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T10:12:06.487758+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T09:00:00+00:00 EmrJobFlowSensor 2023-05-31T10:00:59.382600+00:00 2023-05-31T10:12:01.398670+00:00 0:11:02.016070 388808 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T10:00:57.195400+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T10:00:37.410494+00:00 2023-05-31T10:00:38.346940+00:00 0:00:00.936446 388806 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T10:00:35.183557+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T09:00:00+00:00 PythonOperator 2023-05-31T10:00:17.188752+00:00 2023-05-31T10:00:18.137008+00:00 0:00:00.948256 388804 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T10:00:15.104136+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T08:00:00+00:00 TriggerDagRunOperator 2023-05-31T09:11:24.267157+00:00 2023-05-31T09:11:24.698597+00:00 0:00:00.431440 388794 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T09:11:22.129020+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T08:00:00+00:00 TriggerDagRunOperator 2023-05-31T09:11:24.137706+00:00 2023-05-31T09:11:24.607554+00:00 0:00:00.469848 388793 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T09:11:22.128992+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T08:00:00+00:00 EmrJobFlowSensor 2023-05-31T09:01:04.866323+00:00 2023-05-31T09:11:06.725551+00:00 0:10:01.859228 388787 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T09:01:02.763048+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T09:00:44.875423+00:00 2023-05-31T09:00:45.903021+00:00 0:00:01.027598 388785 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T09:00:42.747888+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T08:00:00+00:00 PythonOperator 2023-05-31T09:00:22.750791+00:00 2023-05-31T09:00:23.684149+00:00 0:00:00.933358 388783 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T09:00:20.724655+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T07:00:00+00:00 TriggerDagRunOperator 2023-05-31T08:32:27.467845+00:00 2023-05-31T08:32:27.919721+00:00 0:00:00.451876 388776 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T08:32:25.175474+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T07:00:00+00:00 TriggerDagRunOperator 2023-05-31T08:32:27.466310+00:00 2023-05-31T08:32:27.907074+00:00 0:00:00.440764 388775 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T08:32:25.175504+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T07:00:00+00:00 EmrJobFlowSensor 2023-05-31T08:07:53.804615+00:00 2023-05-31T08:17:55.715135+00:00 0:10:01.910520 388772 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T08:07:51.343274+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T08:07:31.349935+00:00 2023-05-31T08:07:32.402263+00:00 0:00:01.052328 388768 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T08:07:29.310546+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T07:00:00+00:00 PythonOperator 2023-05-31T08:07:11.298051+00:00 2023-05-31T08:07:12.186125+00:00 0:00:00.888074 388766 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T08:07:09.294153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T06:00:00+00:00 TriggerDagRunOperator 2023-05-31T07:34:14.044081+00:00 2023-05-31T07:34:14.460694+00:00 0:00:00.416613 388756 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T07:34:11.807298+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T06:00:00+00:00 TriggerDagRunOperator 2023-05-31T07:34:13.968936+00:00 2023-05-31T07:34:14.411032+00:00 0:00:00.442096 388755 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T07:34:11.807270+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T06:00:00+00:00 EmrJobFlowSensor 2023-05-31T07:24:08.489816+00:00 2023-05-31T07:34:10.465616+00:00 0:10:01.975800 388750 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T07:24:06.430587+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T07:23:48.444263+00:00 2023-05-31T07:23:49.764014+00:00 0:00:01.319751 388747 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T07:23:46.411927+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T06:00:00+00:00 PythonOperator 2023-05-31T07:23:26.756015+00:00 2023-05-31T07:23:27.679192+00:00 0:00:00.923177 388744 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T07:23:24.393099+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T05:00:00+00:00 TriggerDagRunOperator 2023-05-31T06:11:21.855477+00:00 2023-05-31T06:11:22.332309+00:00 0:00:00.476832 388735 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T06:11:19.386488+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T05:00:00+00:00 TriggerDagRunOperator 2023-05-31T06:11:21.855969+00:00 2023-05-31T06:11:22.343098+00:00 0:00:00.487129 388734 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T06:11:19.386519+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T05:00:00+00:00 EmrJobFlowSensor 2023-05-31T06:00:56.250771+00:00 2023-05-31T06:10:57.959488+00:00 0:10:01.708717 388726 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T06:00:54.189103+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T06:00:36.324027+00:00 2023-05-31T06:00:37.267134+00:00 0:00:00.943107 388724 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T06:00:34.170428+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T05:00:00+00:00 PythonOperator 2023-05-31T06:00:14.395386+00:00 2023-05-31T06:00:15.340734+00:00 0:00:00.945348 388722 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T06:00:12.149867+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T04:00:00+00:00 TriggerDagRunOperator 2023-05-31T05:11:00.757576+00:00 2023-05-31T05:11:01.210794+00:00 0:00:00.453218 388714 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T05:10:58.421468+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T04:00:00+00:00 TriggerDagRunOperator 2023-05-31T05:11:00.673953+00:00 2023-05-31T05:11:01.171798+00:00 0:00:00.497845 388713 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T05:10:58.421440+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T04:00:00+00:00 EmrJobFlowSensor 2023-05-31T05:00:52.472779+00:00 2023-05-31T05:10:54.355532+00:00 0:10:01.882753 388706 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T05:00:50.375399+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T05:00:30.607908+00:00 2023-05-31T05:00:31.503132+00:00 0:00:00.895224 388704 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T05:00:28.394903+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T04:00:00+00:00 PythonOperator 2023-05-31T05:00:10.560005+00:00 2023-05-31T05:00:11.541477+00:00 0:00:00.981472 388702 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T05:00:08.333680+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T03:00:00+00:00 TriggerDagRunOperator 2023-05-31T04:10:52.135112+00:00 2023-05-31T04:10:52.574404+00:00 0:00:00.439292 388692 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T04:10:49.698803+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T03:00:00+00:00 TriggerDagRunOperator 2023-05-31T04:10:52.053814+00:00 2023-05-31T04:10:52.492284+00:00 0:00:00.438470 388691 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T04:10:49.698831+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T03:00:00+00:00 EmrJobFlowSensor 2023-05-31T04:01:39.497445+00:00 2023-05-31T04:10:41.099777+00:00 0:09:01.602332 388685 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T04:01:37.285786+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T04:00:42.753729+00:00 2023-05-31T04:00:43.722334+00:00 0:00:00.968605 388682 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T04:00:40.555293+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T03:00:00+00:00 PythonOperator 2023-05-31T04:00:20.546513+00:00 2023-05-31T04:00:21.509845+00:00 0:00:00.963332 388680 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T04:00:18.534441+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T02:00:00+00:00 TriggerDagRunOperator 2023-05-31T03:11:21.041474+00:00 2023-05-31T03:11:21.553289+00:00 0:00:00.511815 388670 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T03:11:18.796015+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T02:00:00+00:00 TriggerDagRunOperator 2023-05-31T03:11:20.925784+00:00 2023-05-31T03:11:21.505254+00:00 0:00:00.579470 388669 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T03:11:18.795984+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T02:00:00+00:00 EmrJobFlowSensor 2023-05-31T03:00:57.261576+00:00 2023-05-31T03:10:58.986568+00:00 0:10:01.724992 388662 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T03:00:55.093385+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T03:00:35.175953+00:00 2023-05-31T03:00:36.081260+00:00 0:00:00.905307 388660 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T03:00:33.006134+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T02:00:00+00:00 PythonOperator 2023-05-31T03:00:15.209833+00:00 2023-05-31T03:00:16.661994+00:00 0:00:01.452161 388658 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T03:00:13.023674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T01:00:00+00:00 TriggerDagRunOperator 2023-05-31T02:12:32.392417+00:00 2023-05-31T02:12:32.794430+00:00 0:00:00.402013 388648 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T02:12:30.202768+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T01:00:00+00:00 TriggerDagRunOperator 2023-05-31T02:12:32.376526+00:00 2023-05-31T02:12:32.814669+00:00 0:00:00.438143 388647 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T02:12:30.202740+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T01:00:00+00:00 EmrJobFlowSensor 2023-05-31T02:01:04.310191+00:00 2023-05-31T02:11:06.162698+00:00 0:10:01.852507 388641 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T02:01:02.314433+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T02:00:42.592536+00:00 2023-05-31T02:00:43.555208+00:00 0:00:00.962672 388639 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T02:00:40.302738+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T01:00:00+00:00 PythonOperator 2023-05-31T02:00:22.206361+00:00 2023-05-31T02:00:23.138858+00:00 0:00:00.932497 388637 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T02:00:20.228728+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-31T00:00:00+00:00 TriggerDagRunOperator 2023-05-31T01:11:26.126767+00:00 2023-05-31T01:11:26.558163+00:00 0:00:00.431396 388616 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T01:11:23.907728+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-31T00:00:00+00:00 TriggerDagRunOperator 2023-05-31T01:11:26.034581+00:00 2023-05-31T01:11:26.450629+00:00 0:00:00.416048 388615 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T01:11:23.907699+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-31T00:00:00+00:00 EmrJobFlowSensor 2023-05-31T01:01:02.225756+00:00 2023-05-31T01:11:04.090810+00:00 0:10:01.865054 388609 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T01:01:00.253596+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-31T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T01:00:40.114003+00:00 2023-05-31T01:00:41.047040+00:00 0:00:00.933037 388607 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T01:00:38.159093+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-31T00:00:00+00:00 PythonOperator 2023-05-31T01:00:20.116239+00:00 2023-05-31T01:00:21.078261+00:00 0:00:00.962022 388605 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T01:00:18.139734+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T23:00:00+00:00 TriggerDagRunOperator 2023-05-31T00:11:19.945417+00:00 2023-05-31T00:11:20.394083+00:00 0:00:00.448666 388593 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T00:11:17.661857+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T23:00:00+00:00 TriggerDagRunOperator 2023-05-31T00:11:19.873342+00:00 2023-05-31T00:11:20.340176+00:00 0:00:00.466834 388592 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-31T00:11:17.661828+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T23:00:00+00:00 EmrJobFlowSensor 2023-05-31T00:01:08.387212+00:00 2023-05-31T00:11:10.168534+00:00 0:10:01.781322 388586 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-31T00:01:06.257904+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-31T00:00:46.286445+00:00 2023-05-31T00:00:47.195666+00:00 0:00:00.909221 388584 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-31T00:00:44.236650+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T23:00:00+00:00 PythonOperator 2023-05-31T00:00:24.428110+00:00 2023-05-31T00:00:25.335098+00:00 0:00:00.906988 388582 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-31T00:00:22.217313+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T22:00:00+00:00 TriggerDagRunOperator 2023-05-30T23:12:16.478189+00:00 2023-05-30T23:12:16.920733+00:00 0:00:00.442544 388570 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T23:12:14.035675+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T22:00:00+00:00 TriggerDagRunOperator 2023-05-30T23:12:16.434618+00:00 2023-05-30T23:12:16.846649+00:00 0:00:00.412031 388569 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T23:12:14.035648+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T22:00:00+00:00 EmrJobFlowSensor 2023-05-30T23:00:59.544165+00:00 2023-05-30T23:12:01.454522+00:00 0:11:01.910357 388563 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T23:00:57.517062+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T23:00:39.495288+00:00 2023-05-30T23:00:40.385306+00:00 0:00:00.890018 388560 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T23:00:37.498019+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T22:00:00+00:00 PythonOperator 2023-05-30T23:00:17.876302+00:00 2023-05-30T23:00:18.768820+00:00 0:00:00.892518 388557 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T23:00:15.477104+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T21:00:00+00:00 TriggerDagRunOperator 2023-05-30T22:11:18.848974+00:00 2023-05-30T22:11:19.302298+00:00 0:00:00.453324 388544 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T22:11:16.638179+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T21:00:00+00:00 TriggerDagRunOperator 2023-05-30T22:11:18.811445+00:00 2023-05-30T22:11:19.247978+00:00 0:00:00.436533 388543 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T22:11:16.638205+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T21:00:00+00:00 EmrJobFlowSensor 2023-05-30T22:00:55.183313+00:00 2023-05-30T22:10:57.058009+00:00 0:10:01.874696 388537 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T22:00:52.868753+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T22:00:34.950704+00:00 2023-05-30T22:00:35.859840+00:00 0:00:00.909136 388535 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T22:00:32.853973+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T21:00:00+00:00 PythonOperator 2023-05-30T22:00:12.893929+00:00 2023-05-30T22:00:13.845001+00:00 0:00:00.951072 388533 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T22:00:10.833015+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T20:00:00+00:00 TriggerDagRunOperator 2023-05-30T21:11:21.251205+00:00 2023-05-30T21:11:21.731011+00:00 0:00:00.479806 388521 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T21:11:18.803673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T20:00:00+00:00 TriggerDagRunOperator 2023-05-30T21:11:21.221453+00:00 2023-05-30T21:11:21.675967+00:00 0:00:00.454514 388520 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T21:11:18.803645+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T20:00:00+00:00 EmrJobFlowSensor 2023-05-30T21:01:00.746392+00:00 2023-05-30T21:11:02.486922+00:00 0:10:01.740530 388513 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T21:00:58.602211+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T21:00:40.671871+00:00 2023-05-30T21:00:42.248149+00:00 0:00:01.576278 388511 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T21:00:38.539116+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T20:00:00+00:00 PythonOperator 2023-05-30T21:00:18.639185+00:00 2023-05-30T21:00:19.558891+00:00 0:00:00.919706 388509 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T21:00:16.518905+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T19:00:00+00:00 TriggerDagRunOperator 2023-05-30T20:11:14.818263+00:00 2023-05-30T20:11:15.307314+00:00 0:00:00.489051 388498 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T20:11:12.589920+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T19:00:00+00:00 TriggerDagRunOperator 2023-05-30T20:11:14.835606+00:00 2023-05-30T20:11:15.315160+00:00 0:00:00.479554 388497 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T20:11:12.589950+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T19:00:00+00:00 EmrJobFlowSensor 2023-05-30T20:01:06.712684+00:00 2023-05-30T20:11:08.554220+00:00 0:10:01.841536 388491 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T20:01:04.551479+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T20:00:44.641732+00:00 2023-05-30T20:00:45.611360+00:00 0:00:00.969628 388489 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T20:00:42.542029+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T19:00:00+00:00 PythonOperator 2023-05-30T20:00:22.543131+00:00 2023-05-30T20:00:23.522729+00:00 0:00:00.979598 388487 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T20:00:20.508336+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T18:00:00+00:00 TriggerDagRunOperator 2023-05-30T19:11:15.381775+00:00 2023-05-30T19:11:15.814287+00:00 0:00:00.432512 388473 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T19:11:13.167362+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T18:00:00+00:00 TriggerDagRunOperator 2023-05-30T19:11:15.366619+00:00 2023-05-30T19:11:15.816753+00:00 0:00:00.450134 388472 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T19:11:13.167388+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T18:00:00+00:00 EmrJobFlowSensor 2023-05-30T19:01:02.430191+00:00 2023-05-30T19:11:04.232946+00:00 0:10:01.802755 388465 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T19:01:00.303734+00:00 2 default_pool