Skip to content

Commit 818202d

Browse files
akbakb
authored andcommitted
Listify for sync apply
1 parent 1b97781 commit 818202d

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/mario/plugins/basic.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,7 @@ async def async_filter(function, items, exit_stack, max_concurrent):
8787
@registry.add_traversal("apply", calculate_more_params=calculate_function)
8888
async def apply(function, items):
8989
"""When ``function`` takes an iterable."""
90-
return traversals.sync_apply(function, items)
90+
return traversals.AsyncIterableWrapper([await function([x async for x in items])])
9191

9292

9393
@registry.add_traversal("async_apply", calculate_more_params=calculate_function)

0 commit comments

Comments
 (0)