fix: add missing await for getting default user (#1131)
<!-- .github/pull_request_template.md --> ## Description <!-- Provide a clear description of the changes in this PR --> ## DCO Affirmation I affirm that all code in every commit of this pull request conforms to the terms of the Topoteretes Developer Certificate of Origin.
This commit is contained in:
parent
245e88588f
commit
59594e01ac
2 changed files with 2 additions and 2 deletions
|
|
@ -58,7 +58,7 @@ async def run_tasks(
|
|||
context: dict = None,
|
||||
):
|
||||
if not user:
|
||||
user = get_default_user()
|
||||
user = await get_default_user()
|
||||
|
||||
# Get Dataset object
|
||||
db_engine = get_relational_engine()
|
||||
|
|
|
|||
|
|
@ -44,7 +44,7 @@ if modal:
|
|||
|
||||
async def run_tasks_distributed(tasks, dataset_id, data, user, pipeline_name, context):
|
||||
if not user:
|
||||
user = get_default_user()
|
||||
user = await get_default_user()
|
||||
|
||||
db_engine = get_relational_engine()
|
||||
async with db_engine.get_async_session() as session:
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue