Construct RpcServer on each request

Author: cmanallen

src/sentry/scm/endpoints/scm_rpc.py

@@ -14,13 +14,15 @@
     report_error_to_sentry,
 )
 
-server = RpcServer(
-    secrets=settings.SCM_RPC_SHARED_SECRET or [],
-    fetch_repository=fetch_repository,
-    fetch_provider=fetch_service_provider,
-    record_count=record_count_metric,
-    emit_error=report_error_to_sentry,
-)
+
+def make_server():
+    return RpcServer(
+        secrets=settings.SCM_RPC_SHARED_SECRET or [],
+        fetch_repository=fetch_repository,
+        fetch_provider=fetch_service_provider,
+        record_count=record_count_metric,
+        emit_error=report_error_to_sentry,
+    )
 
 
 @internal_cell_silo_endpoint
@@ -38,10 +40,10 @@ class ScmRpcServiceEndpoint(Endpoint):
 
     @sentry_sdk.trace
     def get(self, request: Request) -> HttpResponse:
-        resp = server.get(headers={k: v for k, v in request.headers.items()})
+        resp = make_server().get(headers={k: v for k, v in request.headers.items()})
         return HttpResponse(content=resp.content, status=resp.status_code, headers=resp.headers)
 
     @sentry_sdk.trace
     def post(self, request: Request) -> StreamingHttpResponse:
-        resp = server.post(request.body, headers={k: v for k, v in request.headers.items()})
+        resp = make_server().post(request.body, headers={k: v for k, v in request.headers.items()})
         return StreamingHttpResponse(resp.content, status=resp.status_code, headers=resp.headers)