Differential D4918 Diff 25032 python_modules/libraries/dagster-dask/dagster_dask_tests/test_graphql.py

Changeset View

Standalone View

	Show All 13 Lines
	def test_execute_hammer_through_dagit():			def test_execute_hammer_through_dagit():
	recon_repo = ReconstructableRepository.for_file(			recon_repo = ReconstructableRepository.for_file(
	file_relative_path(__file__, "../../../dagster-test/dagster_test/toys/hammer.py"),			file_relative_path(__file__, "../../../dagster-test/dagster_test/toys/hammer.py"),
	"hammer_pipeline",			"hammer_pipeline",
	)			)
	instance = DagsterInstance.local_temp()			instance = DagsterInstance.local_temp()

	context = DagsterGraphQLContext(			context = DagsterGraphQLContext(
	workspace=Workspace([InProcessRepositoryLocationOrigin(recon_repo.pointer)]),			workspace=Workspace([InProcessRepositoryLocationOrigin(recon_repo)]), instance=instance,
	instance=instance,
	)			)

	selector = infer_pipeline_selector(context, "hammer_pipeline")			selector = infer_pipeline_selector(context, "hammer_pipeline")

	executor = SyncExecutor()			executor = SyncExecutor()

	variables = {			variables = {
	"executionParams": {			"executionParams": {
	Show All 33 Lines