Merge branch 'dev' into fix-plain-txt-file-type
This commit is contained in:
commit
0be56ee762
1 changed files with 1 additions and 0 deletions
|
|
@ -88,6 +88,7 @@ async def run_tasks_distributed(
|
||||||
pipeline_name: str = "unknown_pipeline",
|
pipeline_name: str = "unknown_pipeline",
|
||||||
context: dict = None,
|
context: dict = None,
|
||||||
incremental_loading: bool = False,
|
incremental_loading: bool = False,
|
||||||
|
data_per_batch: int = 20,
|
||||||
):
|
):
|
||||||
if not user:
|
if not user:
|
||||||
user = await get_default_user()
|
user = await get_default_user()
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue