Task Instances

  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 booking-processing-job_v002 check_cluster_status 2021-05-08T04:00:00+00:00 EmrJobFlowSensor 2021-05-08T05:11:07.781082+00:00 2021-05-08T05:20:10.441970+00:00 0:09:02.660888 25718 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T05:11:05.587250+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T05:11:01.904871+00:00 2021-05-08T05:11:03.613194+00:00 0:00:01.708323 25717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T05:10:59.586200+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T05:10:46.004405+00:00 2021-05-08T05:10:47.812108+00:00 0:00:01.807703 25716 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T05:10:43.540805+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T04:00:00+00:00 PythonOperator 2021-05-08T05:10:39.821558+00:00 2021-05-08T05:10:42.854656+00:00 0:00:03.033098 25715 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T05:10:37.640735+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T04:00:00+00:00 PythonOperator 2021-05-08T05:10:24.358051+00:00 2021-05-08T05:10:27.680399+00:00 0:00:03.322348 25714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T05:10:21.506498+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T04:00:00+00:00 TriggerDagRunOperator 2021-05-08T05:10:15.914800+00:00 2021-05-08T05:10:16.493244+00:00 0:00:00.578444 25713 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T05:10:13.559348+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T04:00:00+00:00 TriggerDagRunOperator 2021-05-08T05:10:15.863987+00:00 2021-05-08T05:10:16.286460+00:00 0:00:00.422473 25712 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T05:10:13.559317+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T04:05:00+00:00 EmrJobFlowSensor 2021-05-08T05:06:05.370829+00:00 2021-05-08T05:17:08.271354+00:00 0:11:02.900525 25711 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T05:06:02.990953+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T05:05:43.115699+00:00 2021-05-08T05:05:44.761749+00:00 0:00:01.646050 25710 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T05:05:40.922078+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T04:05:00+00:00 PythonOperator 2021-05-08T05:05:23.001693+00:00 2021-05-08T05:05:26.085216+00:00 0:00:03.083523 25709 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T05:05:20.907539+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T04:00:00+00:00 EmrJobFlowSensor 2021-05-08T05:01:00.777780+00:00 2021-05-08T05:10:03.535071+00:00 0:09:02.757291 25708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T05:00:58.566822+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T05:00:38.752198+00:00 2021-05-08T05:00:40.472480+00:00 0:00:01.720282 25707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T05:00:36.418128+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T04:00:00+00:00 PythonOperator 2021-05-08T05:00:16.773904+00:00 2021-05-08T05:00:19.858985+00:00 0:00:03.085081 25706 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T05:00:14.397010+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T03:00:00+00:00 EmrJobFlowSensor 2021-05-08T04:11:24.581150+00:00 2021-05-08T04:21:27.304816+00:00 0:10:02.723666 25704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T04:11:22.229706+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T03:00:00+00:00 EmrJobFlowSensor 2021-05-08T04:11:12.444655+00:00 2021-05-08T04:20:15.272617+00:00 0:09:02.827962 25703 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T04:11:10.210236+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T04:11:02.497592+00:00 2021-05-08T04:11:04.271745+00:00 0:00:01.774153 25702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T04:11:00.262853+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T04:10:50.320657+00:00 2021-05-08T04:10:52.052746+00:00 0:00:01.732089 25701 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T04:10:48.190148+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T03:00:00+00:00 PythonOperator 2021-05-08T04:10:40.353603+00:00 2021-05-08T04:10:43.398521+00:00 0:00:03.044918 25700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T04:10:38.149474+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T03:00:00+00:00 PythonOperator 2021-05-08T04:10:30.460411+00:00 2021-05-08T04:10:33.817484+00:00 0:00:03.357073 25699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T04:10:28.171166+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T03:00:00+00:00 TriggerDagRunOperator 2021-05-08T04:10:24.583023+00:00 2021-05-08T04:10:25.105321+00:00 0:00:00.522298 25698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T04:10:22.136577+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T03:00:00+00:00 TriggerDagRunOperator 2021-05-08T04:10:24.402707+00:00 2021-05-08T04:10:24.808490+00:00 0:00:00.405783 25697 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T04:10:22.136608+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T03:05:00+00:00 EmrJobFlowSensor 2021-05-08T04:05:55.740660+00:00 2021-05-08T04:14:58.498625+00:00 0:09:02.757965 25696 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T04:05:53.513734+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T04:05:33.697814+00:00 2021-05-08T04:05:35.331994+00:00 0:00:01.634180 25695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T04:05:31.497529+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T03:05:00+00:00 PythonOperator 2021-05-08T04:05:13.738065+00:00 2021-05-08T04:05:16.888715+00:00 0:00:03.150650 25694 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T04:05:11.456710+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T03:00:00+00:00 EmrJobFlowSensor 2021-05-08T04:01:07.358938+00:00 2021-05-08T04:10:10.176000+00:00 0:09:02.817062 25693 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T04:01:05.045850+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T04:00:45.133235+00:00 2021-05-08T04:00:46.817070+00:00 0:00:01.683835 25692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T04:00:42.895307+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T03:00:00+00:00 PythonOperator 2021-05-08T04:00:25.106030+00:00 2021-05-08T04:00:28.147892+00:00 0:00:03.041862 25691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T04:00:22.837734+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T02:00:00+00:00 EmrJobFlowSensor 2021-05-08T03:12:43.280539+00:00 2021-05-08T03:22:46.306397+00:00 0:10:03.025858 25689 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T03:12:40.940636+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T02:00:00+00:00 EmrJobFlowSensor 2021-05-08T03:12:41.125596+00:00 2021-05-08T03:22:43.923736+00:00 0:10:02.798140 25688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T03:12:38.954892+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T03:12:17.125889+00:00 2021-05-08T03:12:18.924915+00:00 0:00:01.799026 25687 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T03:12:14.915681+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T03:12:11.147009+00:00 2021-05-08T03:12:12.877862+00:00 0:00:01.730853 25686 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T03:12:08.917108+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T02:00:00+00:00 PythonOperator 2021-05-08T03:11:53.545537+00:00 2021-05-08T03:11:56.703226+00:00 0:00:03.157689 25685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T03:11:50.954399+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T02:00:00+00:00 PythonOperator 2021-05-08T03:11:47.275137+00:00 2021-05-08T03:11:50.586223+00:00 0:00:03.311086 25684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T03:11:44.898090+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T02:00:00+00:00 TriggerDagRunOperator 2021-05-08T03:11:41.108572+00:00 2021-05-08T03:11:41.656284+00:00 0:00:00.547712 25683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T03:11:38.885617+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T02:00:00+00:00 TriggerDagRunOperator 2021-05-08T03:11:41.049692+00:00 2021-05-08T03:11:41.460647+00:00 0:00:00.410955 25682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T03:11:38.885649+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T02:05:00+00:00 EmrJobFlowSensor 2021-05-08T03:06:00.282945+00:00 2021-05-08T03:14:02.929533+00:00 0:08:02.646588 25681 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T03:05:58.109470+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T03:05:38.159458+00:00 2021-05-08T03:05:39.794882+00:00 0:00:01.635424 25680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T03:05:36.087638+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T02:05:00+00:00 PythonOperator 2021-05-08T03:05:16.290052+00:00 2021-05-08T03:05:19.302913+00:00 0:00:03.012861 25679 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T03:05:14.027497+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T02:00:00+00:00 EmrJobFlowSensor 2021-05-08T03:01:19.893032+00:00 2021-05-08T03:11:22.740913+00:00 0:10:02.847881 25678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T03:01:17.669892+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T03:00:54.090828+00:00 2021-05-08T03:00:55.941563+00:00 0:00:01.850735 25677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T03:00:51.641692+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T02:00:00+00:00 PythonOperator 2021-05-08T03:00:21.907681+00:00 2021-05-08T03:00:25.056460+00:00 0:00:03.148779 25676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T03:00:19.640660+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T01:00:00+00:00 EmrJobFlowSensor 2021-05-08T02:12:45.819259+00:00 2021-05-08T02:21:48.778752+00:00 0:09:02.959493 25674 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T02:12:43.536750+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T01:00:00+00:00 EmrJobFlowSensor 2021-05-08T02:12:35.669418+00:00 2021-05-08T02:21:38.305951+00:00 0:09:02.636533 25673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T02:12:33.530888+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T02:12:25.668959+00:00 2021-05-08T02:12:27.348716+00:00 0:00:01.679757 25672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T02:12:23.522457+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T02:12:11.588576+00:00 2021-05-08T02:12:13.322020+00:00 0:00:01.733444 25671 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T02:12:09.508867+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T01:00:00+00:00 PythonOperator 2021-05-08T02:11:45.665899+00:00 2021-05-08T02:11:48.720766+00:00 0:00:03.054867 25670 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T02:11:43.543478+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T01:00:00+00:00 PythonOperator 2021-05-08T02:11:43.864333+00:00 2021-05-08T02:11:47.247609+00:00 0:00:03.383276 25669 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T02:11:41.549303+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T01:00:00+00:00 TriggerDagRunOperator 2021-05-08T02:11:25.816247+00:00 2021-05-08T02:11:26.416876+00:00 0:00:00.600629 25668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T02:11:23.437417+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T01:00:00+00:00 TriggerDagRunOperator 2021-05-08T02:11:25.685829+00:00 2021-05-08T02:11:26.071122+00:00 0:00:00.385293 25667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T02:11:23.437383+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T01:05:00+00:00 EmrJobFlowSensor 2021-05-08T02:06:01.055275+00:00 2021-05-08T02:15:03.653419+00:00 0:09:02.598144 25666 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T02:05:58.769484+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T02:05:38.827688+00:00 2021-05-08T02:05:40.465724+00:00 0:00:01.638036 25665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T02:05:36.641055+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T01:05:00+00:00 PythonOperator 2021-05-08T02:05:18.766714+00:00 2021-05-08T02:05:21.837033+00:00 0:00:03.070319 25664 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T02:05:16.627750+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T01:00:00+00:00 EmrJobFlowSensor 2021-05-08T02:01:02.512216+00:00 2021-05-08T02:11:05.322634+00:00 0:10:02.810418 25663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T02:01:00.230220+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T02:00:40.486922+00:00 2021-05-08T02:00:42.159820+00:00 0:00:01.672898 25662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T02:00:38.263024+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T01:00:00+00:00 PythonOperator 2021-05-08T02:00:18.652601+00:00 2021-05-08T02:00:21.762314+00:00 0:00:03.109713 25661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T02:00:16.176518+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T00:00:00+00:00 EmrJobFlowSensor 2021-05-08T01:12:34.595638+00:00 2021-05-08T01:22:37.573501+00:00 0:10:02.977863 25659 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T01:12:32.178400+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T00:00:00+00:00 EmrJobFlowSensor 2021-05-08T01:12:28.660083+00:00 2021-05-08T01:20:31.300683+00:00 0:08:02.640600 25658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T01:12:26.177735+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T01:12:12.268995+00:00 2021-05-08T01:12:13.965252+00:00 0:00:01.696257 25657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T01:12:10.116766+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T01:12:08.337627+00:00 2021-05-08T01:12:10.091691+00:00 0:00:01.754064 25656 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T01:12:06.105781+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T00:00:00+00:00 PythonOperator 2021-05-08T01:11:50.585818+00:00 2021-05-08T01:11:53.912010+00:00 0:00:03.326192 25655 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T01:11:48.164811+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T00:00:00+00:00 PythonOperator 2021-05-08T01:11:46.173218+00:00 2021-05-08T01:11:49.279738+00:00 0:00:03.106520 25654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T01:11:44.082756+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T00:00:00+00:00 TriggerDagRunOperator 2021-05-08T01:11:30.733809+00:00 2021-05-08T01:11:31.281901+00:00 0:00:00.548092 25653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T01:11:28.062217+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T00:00:00+00:00 TriggerDagRunOperator 2021-05-08T01:11:30.487345+00:00 2021-05-08T01:11:30.897368+00:00 0:00:00.410023 25652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T01:11:28.062171+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T00:05:00+00:00 EmrJobFlowSensor 2021-05-08T01:05:59.980039+00:00 2021-05-08T01:15:02.732348+00:00 0:09:02.752309 25651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T01:05:57.296371+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T00:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T01:05:37.358292+00:00 2021-05-08T01:05:38.986345+00:00 0:00:01.628053 25650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T01:05:35.257739+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T00:05:00+00:00 PythonOperator 2021-05-08T01:05:11.288397+00:00 2021-05-08T01:05:14.340175+00:00 0:00:03.051778 25649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T01:05:09.185744+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T00:00:00+00:00 EmrJobFlowSensor 2021-05-08T01:01:05.039464+00:00 2021-05-08T01:11:07.887448+00:00 0:10:02.847984 25648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T01:01:02.785312+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T01:00:43.018156+00:00 2021-05-08T01:00:44.700258+00:00 0:00:01.682102 25647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T01:00:40.701959+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T00:00:00+00:00 PythonOperator 2021-05-08T01:00:21.041053+00:00 2021-05-08T01:00:24.262074+00:00 0:00:03.221021 25646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T01:00:18.687095+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T23:00:00+00:00 EmrJobFlowSensor 2021-05-08T00:12:22.078110+00:00 2021-05-08T00:21:24.779601+00:00 0:09:02.701491 25644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T00:12:19.919392+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T23:00:00+00:00 EmrJobFlowSensor 2021-05-08T00:12:10.131282+00:00 2021-05-08T00:22:12.945121+00:00 0:10:02.813839 25643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T00:12:07.904671+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T00:11:56.686706+00:00 2021-05-08T00:11:58.410990+00:00 0:00:01.724284 25642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T00:11:53.962136+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T00:11:48.001905+00:00 2021-05-08T00:11:49.730624+00:00 0:00:01.728719 25641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T00:11:45.836535+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T23:00:00+00:00 PythonOperator 2021-05-08T00:11:34.246935+00:00 2021-05-08T00:11:37.280518+00:00 0:00:03.033583 25640 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T00:11:31.821377+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T23:00:00+00:00 PythonOperator 2021-05-08T00:11:25.902274+00:00 2021-05-08T00:11:29.227228+00:00 0:00:03.324954 25639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T00:11:23.769232+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T23:00:00+00:00 TriggerDagRunOperator 2021-05-08T00:11:10.097042+00:00 2021-05-08T00:11:10.648730+00:00 0:00:00.551688 25638 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T00:11:07.751502+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T23:00:00+00:00 TriggerDagRunOperator 2021-05-08T00:11:09.972877+00:00 2021-05-08T00:11:10.418702+00:00 0:00:00.445825 25637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T00:11:07.751464+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T23:05:00+00:00 EmrJobFlowSensor 2021-05-08T00:06:19.721569+00:00 2021-05-08T00:15:22.490224+00:00 0:09:02.768655 25636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T00:06:17.260077+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T23:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T00:05:57.377994+00:00 2021-05-08T00:05:59.013909+00:00 0:00:01.635915 25635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T00:05:55.175471+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T23:05:00+00:00 PythonOperator 2021-05-08T00:05:27.155005+00:00 2021-05-08T00:05:30.221351+00:00 0:00:03.066346 25634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T00:05:25.093675+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T23:00:00+00:00 EmrJobFlowSensor 2021-05-08T00:00:48.910406+00:00 2021-05-08T00:10:51.830231+00:00 0:10:02.919825 25633 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T00:00:46.611673+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T00:00:27.014763+00:00 2021-05-08T00:00:28.812688+00:00 0:00:01.797925 25632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T00:00:24.593694+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T23:00:00+00:00 PythonOperator 2021-05-08T00:00:05.050684+00:00 2021-05-08T00:00:08.150916+00:00 0:00:03.100232 25631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T00:00:02.543077+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T22:00:00+00:00 EmrJobFlowSensor 2021-05-07T23:12:35.600070+00:00 2021-05-07T23:22:38.252038+00:00 0:10:02.651968 25629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T23:12:33.391340+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T22:00:00+00:00 EmrJobFlowSensor 2021-05-07T23:12:25.493294+00:00 2021-05-07T23:21:28.086090+00:00 0:09:02.592796 25628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T23:12:23.328422+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T23:12:13.654601+00:00 2021-05-07T23:12:15.562860+00:00 0:00:01.908259 25627 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T23:12:11.321112+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T23:12:03.459483+00:00 2021-05-07T23:12:05.148909+00:00 0:00:01.689426 25626 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T23:12:01.314913+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T22:00:00+00:00 PythonOperator 2021-05-07T23:11:41.510978+00:00 2021-05-07T23:11:44.962075+00:00 0:00:03.451097 25625 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T23:11:39.297536+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T22:00:00+00:00 PythonOperator 2021-05-07T23:11:35.477123+00:00 2021-05-07T23:11:38.560679+00:00 0:00:03.083556 25624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T23:11:33.288843+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T22:00:00+00:00 TriggerDagRunOperator 2021-05-07T23:11:17.713935+00:00 2021-05-07T23:11:18.261386+00:00 0:00:00.547451 25623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T23:11:15.252010+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T22:00:00+00:00 TriggerDagRunOperator 2021-05-07T23:11:17.566325+00:00 2021-05-07T23:11:17.968575+00:00 0:00:00.402250 25622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T23:11:15.251976+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T22:05:00+00:00 EmrJobFlowSensor 2021-05-07T23:06:02.626928+00:00 2021-05-07T23:15:05.207959+00:00 0:09:02.581031 25621 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T23:06:00.370358+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T22:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T23:05:40.472616+00:00 2021-05-07T23:05:42.209792+00:00 0:00:01.737176 25620 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T23:05:38.289051+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T22:05:00+00:00 PythonOperator 2021-05-07T23:05:20.363083+00:00 2021-05-07T23:05:23.380944+00:00 0:00:03.017861 25619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T23:05:18.250794+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T22:00:00+00:00 EmrJobFlowSensor 2021-05-07T23:00:58.368676+00:00 2021-05-07T23:11:01.259487+00:00 0:10:02.890811 25618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T23:00:55.928693+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-05-06T23:00:00+00:00 EmrJobFlowSensor 2021-05-07T23:00:56.036566+00:00 2021-05-07T23:09:58.769869+00:00 0:09:02.733303 25617 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T23:00:53.912774+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T23:00:36.345026+00:00 2021-05-07T23:00:38.147766+00:00 0:00:01.802740 25616 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T23:00:33.960124+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-05-06T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T23:00:34.595188+00:00 2021-05-07T23:00:36.287815+00:00 0:00:01.692627 25615 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T23:00:32.168823+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T22:00:00+00:00 PythonOperator 2021-05-07T23:00:14.622847+00:00 2021-05-07T23:00:17.709289+00:00 0:00:03.086442 25614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T23:00:11.941082+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-05-06T23:00:00+00:00 PythonOperator 2021-05-07T23:00:12.712759+00:00 2021-05-07T23:00:15.794900+00:00 0:00:03.082141 25613 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T23:00:09.752717+00:00 2 default_pool