diff --git a/posthog/temporal/tests/test_external_data_job.py b/posthog/temporal/tests/test_external_data_job.py
index 6d3af0de02b3e..edd0f6b79197c 100644
--- a/posthog/temporal/tests/test_external_data_job.py
+++ b/posthog/temporal/tests/test_external_data_job.py
@@ -114,7 +114,7 @@ async def test_create_external_job_activity(activity_environment, team, **kwargs
     assert await sync_to_async(runs.exists)()  # type:ignore
     assert len(schemas) == len(PIPELINE_TYPE_SCHEMA_DEFAULT_MAPPING[new_source.source_type])
 
-    all_schemas = await sync_to_async(get_all_schemas_for_source_id)(new_source.pk, team.pk)
+    all_schemas = await sync_to_async(get_all_schemas_for_source_id)(source_id=new_source.pk, team_id=team.pk)  # type: ignore
     assert len(all_schemas) == len(PIPELINE_TYPE_SCHEMA_MAPPING[new_source.source_type])