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 | drm-migration-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.682086 | 4756 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | drm-migration-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.635702 | 4755 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | drm-migration-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.695769 | 4753 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | drm-migration-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.637797 | 4752 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | drm-migration-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.689451 | 4751 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | drm-migration-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.580005 | 4750 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | drm-migration-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.709719 | 4749 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | drm-migration-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.761475 | 4748 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-past-delete-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.668235 | 4747 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-past-delete-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.643011 | 4746 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-past-delete-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.805463 | 4745 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | drm-migration-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.551449 | 4744 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | drm-migration-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.854676 | 4743 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | drm-migration-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:02:01.709599 | 4742 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | drm-migration-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.706883 | 4741 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | drm-migration-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.663020 | 4740 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | drm-migration-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.709037 | 4739 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | daily-import-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.696393 | 4737 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | daily-import-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.717331 | 4736 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | daily-import-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.638416 | 4735 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:12:03.011745 | 4734 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.680117 | 4733 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.728805 | 4732 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.700208 | 4731 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.607651 | 4730 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.718033 | 4729 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:11:02.929876 | 4728 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.683268 | 4727 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.721503 | 4726 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.493017 | 4725 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.679357 | 4724 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.707766 | 4723 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:12:02.856480 | 4721 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.610643 | 4720 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.781873 | 4719 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | daily-import-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:17:03.665349 | 4701 |
|
airflow | 1 | default |
|
5 | default_pool | |||
success | daily-import-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.682019 | 4700 |
|
airflow | 2 | default |
|
5 | default_pool | |||
success | daily-import-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.769268 | 4699 |
|
airflow | 3 | default |
|
5 | default_pool | |||
success | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.717766 | 4698 |
|
airflow | 1 | default |
|
4 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.677410 | 4697 |
|
airflow | 2 | default |
|
4 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.524769 | 4696 |
|
airflow | 3 | default |
|
4 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.786883 | 4690 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.697316 | 4689 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.741666 | 4688 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.646712 | 4686 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.707498 | 4685 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.771592 | 4684 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.910831 | 4683 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.634565 | 4682 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.802372 | 4681 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | daily-import-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:18:03.829641 | 4679 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | daily-import-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.663412 | 4678 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | daily-import-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.807738 | 4677 |
|
airflow | 3 | default |
|
2 | default_pool | |||
failed | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.686194 | 4676 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.662177 | 4675 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.808605 | 4674 |
|
airflow | 3 | default |
|
2 | default_pool | |||
failed | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.637306 | 4668 |
|
airflow | 3 | default |
|
2 | default_pool | |||
failed | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.566303 | 4667 |
|
airflow | 3 | default |
|
2 | default_pool | |||
failed | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.573803 | 4666 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | daily-import-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:19:03.855021 | 4660 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | daily-import-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.671006 | 4659 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | daily-import-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.730489 | 4658 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.848113 | 4656 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.695928 | 4655 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.705767 | 4654 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.789401 | 4652 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.748816 | 4651 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.767287 | 4650 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.665469 | 4648 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.808423 | 4647 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.686626 | 4646 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.823663 | 4644 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.705000 | 4643 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.677314 | 4642 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.854413 | 4640 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.794174 | 4639 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.692457 | 4638 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.840955 | 4636 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.652263 | 4635 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.688299 | 4634 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.667324 | 4632 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.777617 | 4631 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.723519 | 4630 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.566557 | 4628 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.756206 | 4627 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.719900 | 4626 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.814999 | 4624 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.750406 | 4623 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.699909 | 4622 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.773503 | 4620 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.685830 | 4619 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.819822 | 4618 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.725001 | 4617 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.701388 | 4616 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.671526 | 4615 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.743122 | 4614 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.787555 | 4613 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.779672 | 4612 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.712964 | 4611 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.720974 | 4610 |
|
airflow | 2 | default |
|
2 | default_pool |