Differential D4785 Diff 25946 python_modules/dagster/dagster/cli/debug.py

Changeset View

Standalone View

	from gzip import GzipFile			from gzip import GzipFile

	import click			import click
	from dagster import DagsterInstance			from dagster import DagsterInstance
	from dagster.core.debug import DebugRunPayload			from dagster.core.debug import DebugRunPayload
	from dagster.core.storage.pipeline_run import PipelineRunStatus, PipelineRunsFilter			from dagster.core.storage.pipeline_run import PipelineRunStatus, PipelineRunsFilter


	def _recent_failed_runs_text(instance):			def _recent_failed_runs_text(instance):
	lines = []			lines = []
	runs = instance.get_runs(limit=5, filters=PipelineRunsFilter(status=PipelineRunStatus.FAILURE))			runs = instance.get_runs(
				limit=5, filters=PipelineRunsFilter(statuses=[PipelineRunStatus.FAILURE])
				)
	if len(runs) <= 0:			if len(runs) <= 0:
	return ""			return ""
	for run in runs:			for run in runs:
	lines.append("{:<50}{:<50}{:<20}".format(run.run_id, run.pipeline_name, run.status))			lines.append("{:<50}{:<50}{:<20}".format(run.run_id, run.pipeline_name, run.status))
	return "Recently failed runs:\n{}".format("\n".join(lines))			return "Recently failed runs:\n{}".format("\n".join(lines))


	def create_debug_cli_group():			def create_debug_cli_group():
	Show All 26 Lines