Skip to content

Commit

Permalink
Fix batched pipeline tests
Browse files Browse the repository at this point in the history
  • Loading branch information
yonigozlan committed Oct 24, 2024
1 parent 359160a commit db27af2
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion tests/test_pipeline_mixin.py
Original file line number Diff line number Diff line change
Expand Up @@ -495,7 +495,9 @@ def data(n):
# check if pipeline call signature has more than one argument
# in this case, we can't use a single generator, we need to collate the data first
input_signature = {
k: v for k, v in inspect.signature(pipeline.__call__).parameters.items() if k != "kwargs"
k: v
for k, v in inspect.signature(pipeline.__call__).parameters.items()
if k != "kwargs" and k != "args"
}
if len(input_signature) > 1:
data_list = list(data(10))
Expand Down

0 comments on commit db27af2

Please sign in to comment.