reuse docker client at code_indexing.py

Author: xueyulinn

codehawk/services/code_indexing.py

@@ -13,16 +13,16 @@
 
 
 async def run_code_indexing(payload: dict[str, Any]) -> None:
+    docker_client = DockerRunner()
     pr_ctx = PullRequestWebhookDTO.from_github_webhook_payload(payload)
-    await asyncio.to_thread(clone_repo, pr_ctx)
-    sta_task = asyncio.to_thread(sta_repo, pr_ctx)
-    chunk_task = asyncio.to_thread(chunk_repo, pr_ctx)
+    await asyncio.to_thread(clone_repo, docker_client, pr_ctx)
 
+    sta_task = asyncio.to_thread(sta_repo, docker_client, pr_ctx)
+    chunk_task = asyncio.to_thread(chunk_repo, pr_ctx)
     await asyncio.gather(sta_task, chunk_task)
 
 
-def clone_repo(pr_ctx: PullRequestWebhookDTO) -> None:
-    docker_client = DockerRunner()
+def clone_repo(docker_client: DockerRunner, pr_ctx: PullRequestWebhookDTO) -> None:
     minio_client = get_minio_storage()
     repo_upload_url = minio_client.get_upload_repo_url(
         owner=pr_ctx.owner,
@@ -39,8 +39,7 @@ def clone_repo(pr_ctx: PullRequestWebhookDTO) -> None:
             f"git fetcher failed: {fetcher_logs.decode(errors='replace')}")
 
 
-def sta_repo(pr_ctx: PullRequestWebhookDTO) -> None:
-    docker_client = DockerRunner()
+def sta_repo(docker_client: DockerRunner, pr_ctx: PullRequestWebhookDTO) -> None:
     minio_client = get_minio_storage()
     repo_download_url = minio_client.get_download_repo_url(
         owner=pr_ctx.owner,