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 check_cluster_status 2023-03-11T11:00:00+00:00 EmrJobFlowSensor 2023-03-11T12:12:33.381722+00:00 2023-03-11T12:22:35.168715+00:00 0:10:01.786993 351870 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T12:12:31.134332+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T12:12:13.308976+00:00 2023-03-11T12:12:14.145433+00:00 0:00:00.836457 351867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T12:12:11.105436+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T11:00:00+00:00 PythonOperator 2023-03-11T12:11:51.307451+00:00 2023-03-11T12:11:55.263542+00:00 0:00:03.956091 351864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T12:11:49.071774+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T10:00:00+00:00 TriggerDagRunOperator 2023-03-11T11:11:04.010365+00:00 2023-03-11T11:11:04.545405+00:00 0:00:00.535040 351852 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T11:11:00.971170+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T10:00:00+00:00 TriggerDagRunOperator 2023-03-11T11:11:03.915393+00:00 2023-03-11T11:11:04.420423+00:00 0:00:00.505030 351851 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T11:11:00.971200+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T10:00:00+00:00 EmrJobFlowSensor 2023-03-11T11:00:53.949241+00:00 2023-03-11T11:10:55.730351+00:00 0:10:01.781110 351843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T11:00:51.738504+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T11:00:32.146676+00:00 2023-03-11T11:00:33.044978+00:00 0:00:00.898302 351841 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T11:00:29.695621+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T10:00:00+00:00 PythonOperator 2023-03-11T11:00:12.190551+00:00 2023-03-11T11:00:16.117132+00:00 0:00:03.926581 351839 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T11:00:09.692094+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T09:00:00+00:00 TriggerDagRunOperator 2023-03-11T10:12:08.641805+00:00 2023-03-11T10:12:09.152100+00:00 0:00:00.510295 351831 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T10:12:06.240769+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T09:00:00+00:00 TriggerDagRunOperator 2023-03-11T10:12:08.439600+00:00 2023-03-11T10:12:08.922141+00:00 0:00:00.482541 351830 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T10:12:06.240734+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T09:00:00+00:00 EmrJobFlowSensor 2023-03-11T10:00:47.949108+00:00 2023-03-11T10:11:49.789773+00:00 0:11:01.840665 351821 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T10:00:45.619960+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T10:00:25.784886+00:00 2023-03-11T10:00:26.673236+00:00 0:00:00.888350 351820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T10:00:23.562000+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T09:00:00+00:00 PythonOperator 2023-03-11T10:00:06.444163+00:00 2023-03-11T10:00:10.433626+00:00 0:00:03.989463 351818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T10:00:03.503003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T08:00:00+00:00 TriggerDagRunOperator 2023-03-11T09:12:00.998114+00:00 2023-03-11T09:12:01.462645+00:00 0:00:00.464531 351808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T09:11:58.131211+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T08:00:00+00:00 TriggerDagRunOperator 2023-03-11T09:12:00.732140+00:00 2023-03-11T09:12:01.224297+00:00 0:00:00.492157 351807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T09:11:58.131182+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T08:00:00+00:00 EmrJobFlowSensor 2023-03-11T09:00:55.870946+00:00 2023-03-11T09:10:57.752959+00:00 0:10:01.882013 351799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T09:00:53.340905+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T09:00:35.664645+00:00 2023-03-11T09:00:36.611972+00:00 0:00:00.947327 351797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T09:00:33.325369+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T08:00:00+00:00 PythonOperator 2023-03-11T09:00:13.543719+00:00 2023-03-11T09:00:17.537751+00:00 0:00:03.994032 351795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T09:00:11.206857+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T07:00:00+00:00 TriggerDagRunOperator 2023-03-11T08:17:01.669787+00:00 2023-03-11T08:17:02.199124+00:00 0:00:00.529337 351787 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T08:16:59.064122+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T07:00:00+00:00 TriggerDagRunOperator 2023-03-11T08:17:01.596693+00:00 2023-03-11T08:17:02.107159+00:00 0:00:00.510466 351786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T08:16:59.064093+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T07:00:00+00:00 EmrJobFlowSensor 2023-03-11T08:06:36.432897+00:00 2023-03-11T08:16:38.284965+00:00 0:10:01.852068 351781 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T08:06:34.129334+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T08:06:16.350982+00:00 2023-03-11T08:06:17.556353+00:00 0:00:01.205371 351778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T08:06:14.102131+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T07:00:00+00:00 PythonOperator 2023-03-11T08:05:55.191941+00:00 2023-03-11T08:06:02.303705+00:00 0:00:07.111764 351775 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T08:05:52.080412+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T06:00:00+00:00 TriggerDagRunOperator 2023-03-11T07:23:24.042295+00:00 2023-03-11T07:23:24.496926+00:00 0:00:00.454631 351768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T07:23:21.399265+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T06:00:00+00:00 TriggerDagRunOperator 2023-03-11T07:23:23.800209+00:00 2023-03-11T07:23:24.267941+00:00 0:00:00.467732 351767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T07:23:21.399237+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T06:00:00+00:00 EmrJobFlowSensor 2023-03-11T07:13:13.909387+00:00 2023-03-11T07:23:16.275471+00:00 0:10:02.366084 351763 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T07:13:11.334605+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T07:12:51.752259+00:00 2023-03-11T07:12:53.093739+00:00 0:00:01.341480 351760 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T07:12:49.315799+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T06:00:00+00:00 PythonOperator 2023-03-11T07:12:31.588856+00:00 2023-03-11T07:12:35.527119+00:00 0:00:03.938263 351757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T07:12:29.297003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T05:00:00+00:00 TriggerDagRunOperator 2023-03-11T06:46:16.629677+00:00 2023-03-11T06:46:17.173285+00:00 0:00:00.543608 351750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T06:46:13.508311+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T05:00:00+00:00 TriggerDagRunOperator 2023-03-11T06:46:16.399115+00:00 2023-03-11T06:46:16.934396+00:00 0:00:00.535281 351749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T06:46:13.508347+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T05:00:00+00:00 EmrJobFlowSensor 2023-03-11T06:01:02.730792+00:00 2023-03-11T06:11:04.523319+00:00 0:10:01.792527 351741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T06:01:00.448626+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T06:00:40.886337+00:00 2023-03-11T06:00:41.861763+00:00 0:00:00.975426 351739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T06:00:38.497670+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T05:00:00+00:00 PythonOperator 2023-03-11T06:00:19.151491+00:00 2023-03-11T06:00:23.109599+00:00 0:00:03.958108 351737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T06:00:16.401297+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T04:00:00+00:00 TriggerDagRunOperator 2023-03-11T05:11:15.951128+00:00 2023-03-11T05:11:16.458939+00:00 0:00:00.507811 351730 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T05:11:13.010358+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T04:00:00+00:00 TriggerDagRunOperator 2023-03-11T05:11:15.814080+00:00 2023-03-11T05:11:16.416314+00:00 0:00:00.602234 351729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T05:11:13.010399+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T04:00:00+00:00 EmrJobFlowSensor 2023-03-11T05:00:49.342044+00:00 2023-03-11T05:10:51.032510+00:00 0:10:01.690466 351721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T05:00:47.171855+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T05:00:29.390958+00:00 2023-03-11T05:00:30.283790+00:00 0:00:00.892832 351719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T05:00:27.156074+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T04:00:00+00:00 PythonOperator 2023-03-11T05:00:07.591064+00:00 2023-03-11T05:00:10.711235+00:00 0:00:03.120171 351717 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T05:00:05.129396+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T03:00:00+00:00 TriggerDagRunOperator 2023-03-11T04:39:48.309520+00:00 2023-03-11T04:39:48.835982+00:00 0:00:00.526462 351711 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T04:39:45.264416+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T03:00:00+00:00 TriggerDagRunOperator 2023-03-11T04:39:48.263412+00:00 2023-03-11T04:39:48.760167+00:00 0:00:00.496755 351710 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T04:39:45.264378+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T03:00:00+00:00 EmrJobFlowSensor 2023-03-11T04:14:27.949074+00:00 2023-03-11T04:24:29.715792+00:00 0:10:01.766718 351707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T04:14:25.650696+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T04:14:07.911224+00:00 2023-03-11T04:14:09.313868+00:00 0:00:01.402644 351704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T04:14:03.692784+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T03:00:00+00:00 PythonOperator 2023-03-11T04:13:46.047786+00:00 2023-03-11T04:13:49.143024+00:00 0:00:03.095238 351701 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T04:13:43.591537+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T02:00:00+00:00 TriggerDagRunOperator 2023-03-11T03:18:01.313280+00:00 2023-03-11T03:18:01.837314+00:00 0:00:00.524034 351690 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T03:17:58.396343+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T02:00:00+00:00 TriggerDagRunOperator 2023-03-11T03:18:01.051900+00:00 2023-03-11T03:18:01.541945+00:00 0:00:00.490045 351689 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T03:17:58.396308+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T02:00:00+00:00 EmrJobFlowSensor 2023-03-11T03:00:55.341848+00:00 2023-03-11T03:10:57.239894+00:00 0:10:01.898046 351681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T03:00:52.613420+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T03:00:33.157481+00:00 2023-03-11T03:00:34.070707+00:00 0:00:00.913226 351679 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T03:00:30.603467+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T02:00:00+00:00 PythonOperator 2023-03-11T03:00:11.449168+00:00 2023-03-11T03:00:14.750226+00:00 0:00:03.301058 351677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T03:00:08.530713+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T01:00:00+00:00 TriggerDagRunOperator 2023-03-11T02:11:15.521828+00:00 2023-03-11T02:11:16.064073+00:00 0:00:00.542245 351668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T02:11:13.060159+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T01:00:00+00:00 TriggerDagRunOperator 2023-03-11T02:11:15.456149+00:00 2023-03-11T02:11:15.974535+00:00 0:00:00.518386 351667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T02:11:13.060131+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T01:00:00+00:00 EmrJobFlowSensor 2023-03-11T02:00:48.352224+00:00 2023-03-11T02:10:50.234270+00:00 0:10:01.882046 351660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T02:00:46.035271+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T02:00:26.371031+00:00 2023-03-11T02:00:27.181859+00:00 0:00:00.810828 351658 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T02:00:23.972336+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T01:00:00+00:00 PythonOperator 2023-03-11T02:00:06.347503+00:00 2023-03-11T02:00:10.306528+00:00 0:00:03.959025 351656 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T02:00:03.956900+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T00:00:00+00:00 TriggerDagRunOperator 2023-03-11T01:11:16.143126+00:00 2023-03-11T01:11:16.614418+00:00 0:00:00.471292 351639 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T01:11:13.452208+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T00:00:00+00:00 TriggerDagRunOperator 2023-03-11T01:11:15.916233+00:00 2023-03-11T01:11:16.413998+00:00 0:00:00.497765 351638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T01:11:13.452178+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T00:00:00+00:00 EmrJobFlowSensor 2023-03-11T01:01:08.636105+00:00 2023-03-11T01:11:10.584978+00:00 0:10:01.948873 351632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T01:01:06.108765+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T01:00:48.909811+00:00 2023-03-11T01:00:49.710538+00:00 0:00:00.800727 351630 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T01:00:46.099388+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T00:00:00+00:00 PythonOperator 2023-03-11T01:00:26.564383+00:00 2023-03-11T01:00:29.791645+00:00 0:00:03.227262 351628 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T01:00:23.957537+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T23:00:00+00:00 TriggerDagRunOperator 2023-03-11T00:11:04.851200+00:00 2023-03-11T00:11:05.382606+00:00 0:00:00.531406 351617 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T00:11:02.010474+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T23:00:00+00:00 TriggerDagRunOperator 2023-03-11T00:11:04.809986+00:00 2023-03-11T00:11:05.310612+00:00 0:00:00.500626 351616 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T00:11:02.010519+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T23:00:00+00:00 EmrJobFlowSensor 2023-03-11T00:00:54.913208+00:00 2023-03-11T00:10:56.765213+00:00 0:10:01.852005 351608 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T00:00:52.637153+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T00:00:35.105271+00:00 2023-03-11T00:00:36.008663+00:00 0:00:00.903392 351606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T00:00:32.595753+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T23:00:00+00:00 PythonOperator 2023-03-11T00:00:13.266563+00:00 2023-03-11T00:00:16.599280+00:00 0:00:03.332717 351604 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T00:00:10.579985+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T22:00:00+00:00 TriggerDagRunOperator 2023-03-10T23:11:11.261412+00:00 2023-03-10T23:11:11.831635+00:00 0:00:00.570223 351594 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T23:11:08.391076+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T22:00:00+00:00 TriggerDagRunOperator 2023-03-10T23:11:11.192000+00:00 2023-03-10T23:11:11.671909+00:00 0:00:00.479909 351593 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T23:11:08.391120+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T22:00:00+00:00 EmrJobFlowSensor 2023-03-10T23:01:03.162574+00:00 2023-03-10T23:11:04.907926+00:00 0:10:01.745352 351584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T23:01:00.801027+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T23:00:43.064631+00:00 2023-03-10T23:00:44.180738+00:00 0:00:01.116107 351581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T23:00:40.729195+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T22:00:00+00:00 PythonOperator 2023-03-10T23:00:21.129676+00:00 2023-03-10T23:00:27.264629+00:00 0:00:06.134953 351578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T23:00:18.672407+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T21:00:00+00:00 TriggerDagRunOperator 2023-03-10T22:10:53.795407+00:00 2023-03-10T22:10:54.298586+00:00 0:00:00.503179 351568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T22:10:51.227814+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T21:00:00+00:00 TriggerDagRunOperator 2023-03-10T22:10:53.721076+00:00 2023-03-10T22:10:54.194783+00:00 0:00:00.473707 351567 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T22:10:51.227843+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T21:00:00+00:00 EmrJobFlowSensor 2023-03-10T22:01:46.498889+00:00 2023-03-10T22:10:48.187667+00:00 0:09:01.688778 351561 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T22:01:43.552331+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T22:00:41.917404+00:00 2023-03-10T22:00:42.816125+00:00 0:00:00.898721 351558 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T22:00:39.634096+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T21:00:00+00:00 PythonOperator 2023-03-10T22:00:17.881459+00:00 2023-03-10T22:00:21.017608+00:00 0:00:03.136149 351556 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T22:00:15.606592+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T20:00:00+00:00 TriggerDagRunOperator 2023-03-10T21:11:04.177698+00:00 2023-03-10T21:11:04.671688+00:00 0:00:00.493990 351545 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T21:11:01.273294+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T20:00:00+00:00 TriggerDagRunOperator 2023-03-10T21:11:03.913034+00:00 2023-03-10T21:11:04.395859+00:00 0:00:00.482825 351544 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T21:11:01.273323+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T20:00:00+00:00 EmrJobFlowSensor 2023-03-10T21:01:38.339676+00:00 2023-03-10T21:10:40.055405+00:00 0:09:01.715729 351538 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T21:01:35.565806+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T21:00:44.312678+00:00 2023-03-10T21:00:45.367866+00:00 0:00:01.055188 351535 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T21:00:39.933787+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T20:00:00+00:00 PythonOperator 2023-03-10T21:00:22.088572+00:00 2023-03-10T21:00:26.122407+00:00 0:00:04.033835 351533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T21:00:19.849658+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T19:00:00+00:00 TriggerDagRunOperator 2023-03-10T20:11:09.341798+00:00 2023-03-10T20:11:09.842327+00:00 0:00:00.500529 351522 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T20:11:06.882080+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T19:00:00+00:00 TriggerDagRunOperator 2023-03-10T20:11:09.325875+00:00 2023-03-10T20:11:09.807397+00:00 0:00:00.481522 351521 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T20:11:06.882052+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T19:00:00+00:00 EmrJobFlowSensor 2023-03-10T20:00:50.652678+00:00 2023-03-10T20:10:52.426028+00:00 0:10:01.773350 351513 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T20:00:48.433016+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T20:00:30.655314+00:00 2023-03-10T20:00:31.571614+00:00 0:00:00.916300 351511 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T20:00:28.336203+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T19:00:00+00:00 PythonOperator 2023-03-10T20:00:08.757140+00:00 2023-03-10T20:00:12.263275+00:00 0:00:03.506135 351509 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T20:00:06.269698+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T18:00:00+00:00 TriggerDagRunOperator 2023-03-10T19:11:08.448869+00:00 2023-03-10T19:11:08.947778+00:00 0:00:00.498909 351499 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T19:11:06.036220+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T18:00:00+00:00 TriggerDagRunOperator 2023-03-10T19:11:08.435788+00:00 2023-03-10T19:11:08.887848+00:00 0:00:00.452060 351498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T19:11:06.036249+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T18:00:00+00:00 EmrJobFlowSensor 2023-03-10T19:01:01.607859+00:00 2023-03-10T19:11:03.405494+00:00 0:10:01.797635 351491 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T19:00:59.331676+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T19:00:41.554551+00:00 2023-03-10T19:00:42.488867+00:00 0:00:00.934316 351489 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T19:00:39.297225+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T18:00:00+00:00 PythonOperator 2023-03-10T19:00:19.571994+00:00 2023-03-10T19:00:22.869385+00:00 0:00:03.297391 351487 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T19:00:17.275814+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T17:00:00+00:00 TriggerDagRunOperator 2023-03-10T18:11:37.579216+00:00 2023-03-10T18:11:38.066313+00:00 0:00:00.487097 351477 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T18:11:34.307720+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T17:00:00+00:00 TriggerDagRunOperator 2023-03-10T18:11:37.412047+00:00 2023-03-10T18:11:37.892154+00:00 0:00:00.480107 351476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T18:11:34.307753+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T17:00:00+00:00 EmrJobFlowSensor 2023-03-10T18:00:59.569758+00:00 2023-03-10T18:11:01.473841+00:00 0:10:01.904083 351469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T18:00:57.039955+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T18:00:39.262398+00:00 2023-03-10T18:00:40.065921+00:00 0:00:00.803523 351467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T18:00:37.019348+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T17:00:00+00:00 PythonOperator 2023-03-10T18:00:17.238261+00:00 2023-03-10T18:00:20.344869+00:00 0:00:03.106608 351465 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T18:00:15.004276+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T16:00:00+00:00 TriggerDagRunOperator 2023-03-10T17:12:26.223984+00:00 2023-03-10T17:12:26.690464+00:00 0:00:00.466480 351454 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T17:12:23.708230+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T16:00:00+00:00 TriggerDagRunOperator 2023-03-10T17:12:26.148810+00:00 2023-03-10T17:12:26.630391+00:00 0:00:00.481581 351453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T17:12:23.708200+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T16:00:00+00:00 EmrJobFlowSensor 2023-03-10T17:01:00.148485+00:00 2023-03-10T17:11:02.144812+00:00 0:10:01.996327 351446 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T17:00:57.003825+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T17:00:40.174055+00:00 2023-03-10T17:00:41.055964+00:00 0:00:00.881909 351444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T17:00:34.909055+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T16:00:00+00:00 PythonOperator 2023-03-10T17:00:15.279024+00:00 2023-03-10T17:00:19.954700+00:00 0:00:04.675676 351442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T17:00:12.837200+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T15:00:00+00:00 TriggerDagRunOperator 2023-03-10T16:13:37.302475+00:00 2023-03-10T16:13:37.803954+00:00 0:00:00.501479 351433 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T16:13:34.628220+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T15:00:00+00:00 TriggerDagRunOperator 2023-03-10T16:13:37.124196+00:00 2023-03-10T16:13:37.574964+00:00 0:00:00.450768 351432 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T16:13:34.628262+00:00 2 default_pool