From 3876f8b96ad0f206660698d61814058be62e936b Mon Sep 17 00:00:00 2001 From: Nate Kupp Date: Fri, 12 Jun 2020 14:07:20 -0700 Subject: [PATCH] Remove dagster-celery dep on dagster-k8s Test Plan: buildkite, tested manually in a new clean venv Reviewers: alangenfeld, catherinewu, schrockn Reviewed By: schrockn Subscribers: schrockn, max Differential Revision: https://dagster.phacility.com/D3479 --- .../libraries/dagster-celery/dagster_celery/engine.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/python_modules/libraries/dagster-celery/dagster_celery/engine.py b/python_modules/libraries/dagster-celery/dagster_celery/engine.py index 160d89d71eca3..bdde44c297de8 100644 --- a/python_modules/libraries/dagster-celery/dagster_celery/engine.py +++ b/python_modules/libraries/dagster-celery/dagster_celery/engine.py @@ -1,8 +1,6 @@ import sys import time -from dagster_k8s.job import get_k8s_resource_requirements - from dagster import check from dagster.core.engine.engine_base import Engine from dagster.core.errors import DagsterSubprocessError @@ -189,6 +187,8 @@ def _submit_task(app, pipeline_context, step, queue, priority): def _submit_task_k8s_job(app, pipeline_context, step, queue, priority): from .tasks import create_k8s_job_task + from dagster_k8s.job import get_k8s_resource_requirements + resources = get_k8s_resource_requirements(step.tags) task = create_k8s_job_task(app)