Differential D8231 Diff 39295 integration_tests/test_suites/k8s-integration-test-suite/test_integration.py

Changeset View

Standalone View

Show First 20 Lines • Show All 130 Lines • ▼ Show 20 Lines	):

start_time = datetime.datetime.now()		start_time = datetime.datetime.now()

while datetime.datetime.now() < start_time + timeout:		while datetime.datetime.now() < start_time + timeout:
event_records = dagster_instance_for_k8s_run_launcher.all_logs(run.run_id)		event_records = dagster_instance_for_k8s_run_launcher.all_logs(run.run_id)

for event_record in event_records:		for event_record in event_records:
if event_record.dagster_event:		if event_record.dagster_event:
if (		if event_record.dagster_event.event_type == DagsterEventType.PIPELINE_FAILURE:
event_record.dagster_event.event_type
== DagsterEventType.PIPELINE_INIT_FAILURE
):
found_pipeline_failure = True		found_pipeline_failure = True

if found_pipeline_failure:		if found_pipeline_failure:
break		break

time.sleep(5)		time.sleep(5)

assert found_pipeline_failure		assert found_pipeline_failure
▲ Show 20 Lines • Show All 111 Lines • Show Last 20 Lines