diff --git a/src/airflow/dags/common_airflow.py b/src/airflow/dags/common_airflow.py index f3ec89bb2..39e0ad425 100644 --- a/src/airflow/dags/common_airflow.py +++ b/src/airflow/dags/common_airflow.py @@ -112,6 +112,7 @@ def create_cluster( num_workers=num_workers, image_version=GCP_DATAPROC_IMAGE, enable_component_gateway=True, + optional_components=["JUPYTER"], init_actions_uris=INITIALISATION_EXECUTABLE_FILE, metadata={ "CONFIGTAR": CONFIG_TAG,