Skip to content

Commit

Permalink
fix lint
Browse files Browse the repository at this point in the history
  • Loading branch information
longquanzheng committed Sep 11, 2023
1 parent f771d32 commit ff47dde
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions iwf/worker_service.py
Original file line number Diff line number Diff line change
Expand Up @@ -76,15 +76,15 @@ def handle_workflow_worker_rpc(
communication = Communication(
internal_channel_types, self._options.object_encoder
)
params = []
params: typing.Any = []
if rpc_info.params_order is not None:
for param_type in rpc_info.params_order:
if param_type == Persistence:
params.append(persistence)
elif param_type == Communication:
params.append(communication) # TODO why mypy shows error here?
params.append(communication)
elif param_type == WorkflowContext:
params.append(context) # TODO why mypy shows error here?
params.append(context)
else:
params.append(_input)

Expand Down

0 comments on commit ff47dde

Please sign in to comment.