diff --git a/owilix/core/tasks/query.py b/owilix/core/tasks/query.py index 5a2f354..f697b69 100644 --- a/owilix/core/tasks/query.py +++ b/owilix/core/tasks/query.py @@ -468,7 +468,7 @@ def slice_query( prefetch=prefetch ) - for results in db.query_and_copy(): + for results in db.query_aggregator(): if not results.success: if console: console.print(f"[red]Error: {results.error}[/red]") @@ -531,7 +531,7 @@ def slice_query( return CommandResult( success=success, - data={"dataset": target_ds}, + object={"dataset": target_ds}, msg=f"Slice {'completed' if success else 'failed'}" )