Skip to content

Commit

Permalink
Remove dagster-celery dep on dagster-k8s
Browse files Browse the repository at this point in the history
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
  • Loading branch information
Nate Kupp committed Jun 12, 2020
1 parent 4a39d23 commit 3876f8b
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
@@ -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
Expand Down Expand Up @@ -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)

Expand Down

0 comments on commit 3876f8b

Please sign in to comment.