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 campaign-history-job_v002 create_emr_steps 2021-04-27T12:00:00+00:00 PythonOperator 2021-04-27T13:13:06.062452+00:00 2021-04-27T13:13:09.040232+00:00 0:00:02.977780 21841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T13:13:03.510201+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T12:00:00+00:00 TriggerDagRunOperator 2021-04-27T13:12:58.177100+00:00 2021-04-27T13:12:58.690700+00:00 0:00:00.513600 21840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T13:12:55.502653+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T12:00:00+00:00 TriggerDagRunOperator 2021-04-27T13:12:58.189286+00:00 2021-04-27T13:12:58.760327+00:00 0:00:00.571041 21839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T13:12:55.502681+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T12:05:00+00:00 EmrJobFlowSensor 2021-04-27T13:06:04.876526+00:00 2021-04-27T13:14:07.561078+00:00 0:08:02.684552 21837 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T13:06:02.497476+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T13:05:42.549826+00:00 2021-04-27T13:05:44.206634+00:00 0:00:01.656808 21836 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T13:05:40.417259+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T12:05:00+00:00 PythonOperator 2021-04-27T13:05:18.839724+00:00 2021-04-27T13:05:21.843077+00:00 0:00:03.003353 21835 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T13:05:16.393877+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T12:00:00+00:00 EmrJobFlowSensor 2021-04-27T13:01:04.436188+00:00 2021-04-27T13:10:07.224119+00:00 0:09:02.787931 21834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T13:01:02.084483+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T13:00:42.294050+00:00 2021-04-27T13:00:44.007592+00:00 0:00:01.713542 21833 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T13:00:40.039597+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T12:00:00+00:00 PythonOperator 2021-04-27T13:00:22.273353+00:00 2021-04-27T13:00:25.292732+00:00 0:00:03.019379 21832 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T13:00:20.024113+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T11:00:00+00:00 EmrJobFlowSensor 2021-04-27T12:12:23.712610+00:00 2021-04-27T12:21:26.311133+00:00 0:09:02.598523 21831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T12:12:21.482859+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T11:00:00+00:00 EmrJobFlowSensor 2021-04-27T12:12:20.117867+00:00 2021-04-27T12:22:23.106799+00:00 0:10:02.988932 21830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T12:12:17.553309+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T12:12:02.379830+00:00 2021-04-27T12:12:04.107056+00:00 0:00:01.727226 21829 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T12:11:59.547752+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T12:11:59.928243+00:00 2021-04-27T12:12:02.085150+00:00 0:00:02.156907 21828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T12:11:57.541807+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T11:00:00+00:00 PythonOperator 2021-04-27T12:11:39.685186+00:00 2021-04-27T12:11:42.710376+00:00 0:00:03.025190 21827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T12:11:37.392164+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T11:00:00+00:00 PythonOperator 2021-04-27T12:11:37.734710+00:00 2021-04-27T12:11:40.961728+00:00 0:00:03.227018 21826 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T12:11:35.389348+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T11:00:00+00:00 TriggerDagRunOperator 2021-04-27T12:11:21.718210+00:00 2021-04-27T12:11:22.264929+00:00 0:00:00.546719 21825 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T12:11:19.326590+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T11:00:00+00:00 TriggerDagRunOperator 2021-04-27T12:11:21.628058+00:00 2021-04-27T12:11:22.058512+00:00 0:00:00.430454 21824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T12:11:19.326557+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T11:05:00+00:00 EmrJobFlowSensor 2021-04-27T12:09:19.310710+00:00 2021-04-27T12:18:21.926649+00:00 0:09:02.615939 21823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T12:09:17.190519+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T12:08:57.282798+00:00 2021-04-27T12:08:58.906415+00:00 0:00:01.623617 21822 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T12:08:55.144885+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T11:05:00+00:00 PythonOperator 2021-04-27T12:08:37.539714+00:00 2021-04-27T12:08:40.533567+00:00 0:00:02.993853 21821 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T12:08:35.133287+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T11:00:00+00:00 EmrJobFlowSensor 2021-04-27T12:01:07.531833+00:00 2021-04-27T12:11:10.358965+00:00 0:10:02.827132 21819 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T12:01:05.059465+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T12:00:45.256086+00:00 2021-04-27T12:00:46.989716+00:00 0:00:01.733630 21818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T12:00:42.962253+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T11:00:00+00:00 PythonOperator 2021-04-27T12:00:23.143924+00:00 2021-04-27T12:00:26.105993+00:00 0:00:02.962069 21817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T12:00:20.943154+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T10:00:00+00:00 EmrJobFlowSensor 2021-04-27T11:11:12.242965+00:00 2021-04-27T11:21:15.041815+00:00 0:10:02.798850 21816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T11:11:09.925950+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T10:00:00+00:00 EmrJobFlowSensor 2021-04-27T11:11:04.222644+00:00 2021-04-27T11:20:06.876779+00:00 0:09:02.654135 21815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T11:11:01.912205+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T11:10:50.652107+00:00 2021-04-27T11:10:52.299251+00:00 0:00:01.647144 21814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T11:10:47.956570+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T11:10:42.305287+00:00 2021-04-27T11:10:43.983135+00:00 0:00:01.677848 21813 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T11:10:39.943979+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T10:00:00+00:00 PythonOperator 2021-04-27T11:10:30.593237+00:00 2021-04-27T11:10:33.872620+00:00 0:00:03.279383 21812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T11:10:27.967018+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T10:00:00+00:00 PythonOperator 2021-04-27T11:10:22.075118+00:00 2021-04-27T11:10:25.082686+00:00 0:00:03.007568 21811 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T11:10:19.851370+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T10:00:00+00:00 TriggerDagRunOperator 2021-04-27T11:10:04.329252+00:00 2021-04-27T11:10:05.082778+00:00 0:00:00.753526 21810 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T11:10:01.840852+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T10:00:00+00:00 TriggerDagRunOperator 2021-04-27T11:10:04.216219+00:00 2021-04-27T11:10:04.820872+00:00 0:00:00.604653 21809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T11:10:01.840818+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T10:05:00+00:00 EmrJobFlowSensor 2021-04-27T11:05:49.675332+00:00 2021-04-27T11:14:52.232527+00:00 0:09:02.557195 21808 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T11:05:47.549015+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T11:05:27.818475+00:00 2021-04-27T11:05:29.418332+00:00 0:00:01.599857 21807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T11:05:25.579008+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T10:05:00+00:00 PythonOperator 2021-04-27T11:05:07.857721+00:00 2021-04-27T11:05:10.773465+00:00 0:00:02.915744 21806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T11:05:05.511928+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T10:00:00+00:00 EmrJobFlowSensor 2021-04-27T11:00:48.176969+00:00 2021-04-27T11:09:50.813082+00:00 0:09:02.636113 21804 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T11:00:45.901110+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T11:00:26.107792+00:00 2021-04-27T11:00:27.842248+00:00 0:00:01.734456 21803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T11:00:23.877976+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T10:00:00+00:00 PythonOperator 2021-04-27T11:00:06.158793+00:00 2021-04-27T11:00:09.200921+00:00 0:00:03.042128 21802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T11:00:03.859085+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T09:00:00+00:00 EmrJobFlowSensor 2021-04-27T10:10:26.037196+00:00 2021-04-27T10:20:28.852083+00:00 0:10:02.814887 21801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T10:10:23.745265+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T09:00:00+00:00 EmrJobFlowSensor 2021-04-27T10:10:16.083475+00:00 2021-04-27T10:18:18.596433+00:00 0:08:02.512958 21800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T10:10:13.847487+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T10:10:04.088916+00:00 2021-04-27T10:10:05.754784+00:00 0:00:01.665868 21799 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T10:10:01.718471+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T10:09:45.889131+00:00 2021-04-27T10:09:47.552575+00:00 0:00:01.663444 21798 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T10:09:43.691151+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T09:00:00+00:00 PythonOperator 2021-04-27T10:09:35.860851+00:00 2021-04-27T10:09:39.030688+00:00 0:00:03.169837 21797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T10:09:33.678457+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T09:00:00+00:00 PythonOperator 2021-04-27T10:09:20.482074+00:00 2021-04-27T10:09:23.529774+00:00 0:00:03.047700 21796 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T10:09:17.663373+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T09:00:00+00:00 TriggerDagRunOperator 2021-04-27T10:09:12.143317+00:00 2021-04-27T10:09:12.670618+00:00 0:00:00.527301 21795 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T10:09:09.678496+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T09:00:00+00:00 TriggerDagRunOperator 2021-04-27T10:09:12.045796+00:00 2021-04-27T10:09:12.502484+00:00 0:00:00.456688 21794 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T10:09:09.678543+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T09:05:00+00:00 EmrJobFlowSensor 2021-04-27T10:05:51.293720+00:00 2021-04-27T10:14:53.887292+00:00 0:09:02.593572 21793 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T10:05:49.189002+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T10:05:29.328108+00:00 2021-04-27T10:05:30.948347+00:00 0:00:01.620239 21792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T10:05:27.169614+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T09:05:00+00:00 PythonOperator 2021-04-27T10:05:07.348403+00:00 2021-04-27T10:05:10.375859+00:00 0:00:03.027456 21791 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T10:05:05.142307+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T09:00:00+00:00 EmrJobFlowSensor 2021-04-27T10:00:57.280495+00:00 2021-04-27T10:08:59.845182+00:00 0:08:02.564687 21789 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T10:00:55.138698+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T10:00:35.384722+00:00 2021-04-27T10:00:37.183235+00:00 0:00:01.798513 21788 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T10:00:33.115163+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T09:00:00+00:00 PythonOperator 2021-04-27T10:00:13.629574+00:00 2021-04-27T10:00:16.625974+00:00 0:00:02.996400 21787 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T10:00:11.163757+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T08:00:00+00:00 EmrJobFlowSensor 2021-04-27T09:13:13.164406+00:00 2021-04-27T09:30:16.865321+00:00 0:17:03.700915 21786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T09:13:10.794212+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T08:00:00+00:00 EmrJobFlowSensor 2021-04-27T09:13:03.014407+00:00 2021-04-27T09:23:05.887041+00:00 0:10:02.872634 21785 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T09:13:00.744267+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T09:12:50.918031+00:00 2021-04-27T09:12:52.723327+00:00 0:00:01.805296 21784 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T09:12:48.653793+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T09:12:40.919445+00:00 2021-04-27T09:12:42.617031+00:00 0:00:01.697586 21783 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T09:12:38.657820+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T08:00:00+00:00 PythonOperator 2021-04-27T09:12:30.982756+00:00 2021-04-27T09:12:34.528027+00:00 0:00:03.545271 21782 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T09:12:28.448749+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T08:00:00+00:00 PythonOperator 2021-04-27T09:12:20.572707+00:00 2021-04-27T09:12:23.932456+00:00 0:00:03.359749 21781 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T09:12:18.275070+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T08:00:00+00:00 TriggerDagRunOperator 2021-04-27T09:12:08.685991+00:00 2021-04-27T09:12:09.208112+00:00 0:00:00.522121 21780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T09:12:06.195665+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T08:00:00+00:00 TriggerDagRunOperator 2021-04-27T09:12:08.501311+00:00 2021-04-27T09:12:08.920639+00:00 0:00:00.419328 21779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T09:12:06.195706+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T08:05:00+00:00 EmrJobFlowSensor 2021-04-27T09:06:01.846224+00:00 2021-04-27T09:15:04.442879+00:00 0:09:02.596655 21778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T09:05:59.541230+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T09:05:39.968208+00:00 2021-04-27T09:05:41.723537+00:00 0:00:01.755329 21777 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T09:05:37.481190+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T08:05:00+00:00 PythonOperator 2021-04-27T09:05:19.544995+00:00 2021-04-27T09:05:22.510885+00:00 0:00:02.965890 21776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T09:05:17.390821+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T08:00:00+00:00 EmrJobFlowSensor 2021-04-27T09:02:59.462077+00:00 2021-04-27T09:12:02.235150+00:00 0:09:02.773073 21775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T09:02:57.196725+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T09:02:37.437859+00:00 2021-04-27T09:02:39.216311+00:00 0:00:01.778452 21774 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T09:02:35.162676+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T08:00:00+00:00 PythonOperator 2021-04-27T09:02:17.736152+00:00 2021-04-27T09:02:20.717815+00:00 0:00:02.981663 21773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T09:02:15.017282+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T07:00:00+00:00 EmrJobFlowSensor 2021-04-27T08:12:20.636558+00:00 2021-04-27T08:23:23.669649+00:00 0:11:03.033091 21771 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T08:12:18.200453+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T07:00:00+00:00 EmrJobFlowSensor 2021-04-27T08:12:16.583243+00:00 2021-04-27T08:22:19.430400+00:00 0:10:02.847157 21770 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T08:12:14.195098+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T08:11:58.460864+00:00 2021-04-27T08:12:00.290826+00:00 0:00:01.829962 21769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T08:11:56.265883+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T08:11:54.468005+00:00 2021-04-27T08:11:56.255300+00:00 0:00:01.787295 21768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T08:11:52.153494+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T07:00:00+00:00 PythonOperator 2021-04-27T08:11:38.802173+00:00 2021-04-27T08:11:42.159425+00:00 0:00:03.357252 21767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T08:11:36.141737+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T07:00:00+00:00 PythonOperator 2021-04-27T08:11:34.341903+00:00 2021-04-27T08:11:37.749917+00:00 0:00:03.408014 21766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T08:11:32.142375+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T07:00:00+00:00 TriggerDagRunOperator 2021-04-27T08:11:14.808911+00:00 2021-04-27T08:11:15.232730+00:00 0:00:00.423819 21765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T08:11:12.125786+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T07:00:00+00:00 TriggerDagRunOperator 2021-04-27T08:11:14.425014+00:00 2021-04-27T08:11:14.958574+00:00 0:00:00.533560 21764 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T08:11:12.125754+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T07:05:00+00:00 EmrJobFlowSensor 2021-04-27T08:06:02.047767+00:00 2021-04-27T08:15:04.743170+00:00 0:09:02.695403 21763 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T08:05:59.579333+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T08:05:39.961665+00:00 2021-04-27T08:05:41.675860+00:00 0:00:01.714195 21762 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T08:05:37.570743+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T07:05:00+00:00 PythonOperator 2021-04-27T08:05:19.502817+00:00 2021-04-27T08:05:22.490790+00:00 0:00:02.987973 21761 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T08:05:17.284864+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T07:00:00+00:00 EmrJobFlowSensor 2021-04-27T08:01:03.316409+00:00 2021-04-27T08:11:06.110521+00:00 0:10:02.794112 21760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T08:01:00.860062+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T08:00:41.261609+00:00 2021-04-27T08:00:43.093268+00:00 0:00:01.831659 21759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T08:00:38.879777+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T07:00:00+00:00 PythonOperator 2021-04-27T08:00:19.318799+00:00 2021-04-27T08:00:22.279410+00:00 0:00:02.960611 21758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T08:00:16.862742+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T06:00:00+00:00 EmrJobFlowSensor 2021-04-27T07:12:12.678293+00:00 2021-04-27T07:24:15.743581+00:00 0:12:03.065288 21756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T07:12:10.496281+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T06:00:00+00:00 EmrJobFlowSensor 2021-04-27T07:12:02.912993+00:00 2021-04-27T07:21:05.725221+00:00 0:09:02.812228 21755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T07:12:00.554470+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T07:11:51.017943+00:00 2021-04-27T07:11:52.797060+00:00 0:00:01.779117 21754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T07:11:48.486554+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T07:11:40.592681+00:00 2021-04-27T07:11:42.368123+00:00 0:00:01.775442 21753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T07:11:38.423840+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T06:00:00+00:00 PythonOperator 2021-04-27T07:11:31.071564+00:00 2021-04-27T07:11:34.388925+00:00 0:00:03.317361 21752 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T07:11:28.544390+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T06:00:00+00:00 PythonOperator 2021-04-27T07:11:19.708431+00:00 2021-04-27T07:11:22.870148+00:00 0:00:03.161717 21751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T07:11:16.541115+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T06:00:00+00:00 TriggerDagRunOperator 2021-04-27T07:11:10.862224+00:00 2021-04-27T07:11:11.376311+00:00 0:00:00.514087 21750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T07:11:08.425690+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T06:00:00+00:00 TriggerDagRunOperator 2021-04-27T07:11:10.812823+00:00 2021-04-27T07:11:11.239955+00:00 0:00:00.427132 21749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T07:11:08.425734+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T06:05:00+00:00 EmrJobFlowSensor 2021-04-27T07:06:04.534920+00:00 2021-04-27T07:14:07.233429+00:00 0:08:02.698509 21748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T07:06:01.968030+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T07:05:42.198064+00:00 2021-04-27T07:05:43.996677+00:00 0:00:01.798613 21747 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T07:05:39.853416+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T06:05:00+00:00 PythonOperator 2021-04-27T07:05:21.882382+00:00 2021-04-27T07:05:24.843170+00:00 0:00:02.960788 21746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T07:05:19.766498+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T06:00:00+00:00 EmrJobFlowSensor 2021-04-27T07:00:47.330699+00:00 2021-04-27T07:10:50.191882+00:00 0:10:02.861183 21745 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T07:00:44.995763+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T07:00:25.240501+00:00 2021-04-27T07:00:26.907061+00:00 0:00:01.666560 21744 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T07:00:22.956328+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T06:00:00+00:00 PythonOperator 2021-04-27T07:00:05.570828+00:00 2021-04-27T07:00:08.569159+00:00 0:00:02.998331 21743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T07:00:02.956833+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T05:00:00+00:00 EmrJobFlowSensor 2021-04-27T06:22:03.960007+00:00 2021-04-27T06:22:05.509030+00:00 0:00:01.549023 21741 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T06:22:01.683964+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T05:00:00+00:00 EmrJobFlowSensor 2021-04-27T06:10:12.211477+00:00 2021-04-27T06:18:14.858413+00:00 0:08:02.646936 21739 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T06:10:10.050977+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T06:09:56.421374+00:00 2021-04-27T06:09:58.106941+00:00 0:00:01.685567 21738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T06:09:54.141114+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T06:09:50.293138+00:00 2021-04-27T06:09:52.087243+00:00 0:00:01.794105 21737 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T06:09:48.051487+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T05:00:00+00:00 PythonOperator 2021-04-27T06:09:34.520633+00:00 2021-04-27T06:09:37.769046+00:00 0:00:03.248413 21736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T06:09:31.993155+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T05:00:00+00:00 PythonOperator 2021-04-27T06:09:30.502731+00:00 2021-04-27T06:09:33.908908+00:00 0:00:03.406177 21735 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T06:09:27.964846+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T05:00:00+00:00 TriggerDagRunOperator 2021-04-27T06:09:12.109388+00:00 2021-04-27T06:09:12.670600+00:00 0:00:00.561212 21734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T06:09:09.836460+00:00 2 default_pool