Skip to content

Commit

Permalink
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion hamilton/async_driver.py
Original file line number Diff line number Diff line change
@@ -355,8 +355,9 @@ async def execute(
start_time = time.time()
run_successful = True
error = None
_final_vars = self._create_final_vars(final_vars)
try:
outputs = await self.raw_execute(final_vars, overrides, display_graph, inputs=inputs)
outputs = await self.raw_execute(_final_vars, overrides, display_graph, inputs=inputs)
# Currently we don't allow async build results, but we could.
if self.adapter.does_method("do_build_result", is_async=False):
return self.adapter.call_lifecycle_method_sync("do_build_result", outputs=outputs)

0 comments on commit 994b6ee

Please sign in to comment.