Skip to content

Commit

Permalink
Simplify execute_in_process result (#8365)
Browse files Browse the repository at this point in the history
Summary:
I think the only part of https://github.com/dagster-io/dagster/pull/6784/files that we needed was the part where the run is reloaded from the DB - the new test added in that PR still passes.

Test Plan: BK
  • Loading branch information
gibsondan committed Jun 13, 2022
1 parent fc6fdeb commit d954334
Showing 1 changed file with 1 addition and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -81,13 +81,7 @@ def core_execute_in_process(
),
)

event_list = []

for event in execute_run_iterable:
event_list.append(event)

if event.is_pipeline_event:
execute_instance.handle_run_event(run_id, event)
event_list = list(execute_run_iterable)

return ExecuteInProcessResult(
node, event_list, execute_instance.get_run_by_id(run_id), output_capture
Expand Down

0 comments on commit d954334

Please sign in to comment.