Skip to content
This repository was archived by the owner on Feb 20, 2025. It is now read-only.

Commit d556b81

Browse files
committed
fix: types
1 parent a735a9c commit d556b81

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

hatchet_sdk/worker/runner/runner.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -225,7 +225,7 @@ def inner_callback(task: asyncio.Task[Any]) -> None:
225225
return inner_callback
226226

227227
## TODO: Stricter type hinting here
228-
def thread_action_func(self, context: Context, step: Step[T], action: Action) -> T:
228+
def thread_action_func(self, context: Context, step: "Step[T]", action: Action) -> T:
229229
if action.step_run_id is not None and action.step_run_id != "":
230230
self.threads[action.step_run_id] = current_thread()
231231
elif (
@@ -241,7 +241,7 @@ def thread_action_func(self, context: Context, step: Step[T], action: Action) ->
241241
async def async_wrapped_action_func(
242242
self,
243243
context: Context,
244-
step: Step[T],
244+
step: "Step[T]",
245245
action: Action,
246246
run_id: str,
247247
) -> T:

0 commit comments

Comments
 (0)