diff --git a/airflow/gcp/example_dags/example_mlengine.py b/airflow/gcp/example_dags/example_mlengine.py index 203e7f2f7347a..6df050a98c639 100644 --- a/airflow/gcp/example_dags/example_mlengine.py +++ b/airflow/gcp/example_dags/example_mlengine.py @@ -145,7 +145,7 @@ prediction = MLEngineBatchPredictionOperator( task_id="prediction", - project_id="polidea-airflow", + project_id=PROJECT_ID, job_id="prediciton-{{ ts_nodash }}-{{ params.model_name }}", region="us-central1", model_name=MODEL_NAME,