Merge pull request #462 from ropable/master

Gunicorn reconfiguration to use native ASGI worker

Author: ropable

gunicorn.py

@@ -1,16 +1,19 @@
 # Gunicorn configuration settings.
-import multiprocessing
 
 bind = ":8080"
-# Don't start too many workers:
-workers = min(multiprocessing.cpu_count(), 4)
-# Give workers an expiry:
+workers = 4
+worker_connections = 1000  # Max connections per worker
 max_requests = 2048
 max_requests_jitter = 256
 preload_app = True
-# Set longer timeout for workers
-timeout = 180
+keepalive = 5  # Keepalive timeout
+timeout = 180  # Worker timeout
+graceful_timeout = 30  # Graceful shutdown timeout
 # Disable access logging.
 accesslog = None
-# Use UvicornWorker as the worker class.
-worker_class = "resource_tracking.workers.UvicornWorker"
+
+# asgi configuration
+worker_class = "asgi"
+asgi_loop = "auto"  # Uses uvloop if available
+asgi_lifespan = "auto"  # Auto-detect lifespan support
+control_socket = "/tmp/gunicorn.ctl"

kustomize/base/deployment.yaml

@@ -25,7 +25,7 @@ spec:
           resources:
             requests:
               memory: '100Mi'
-              cpu: '5m'
+              cpu: '10m'
             limits:
               memory: '2Gi'
               cpu: '1000m'

pyproject.toml

@@ -25,14 +25,13 @@ dependencies = [
   "sentry-sdk[django]==2.53.0",
   "django-geojson==4.2.0",
   "azure-storage-blob==12.28.0",
-  "uvicorn[standard]==0.41.0",
-  "uvicorn-worker==0.4.0",
   "orjson==3.11.7",
   "django-crispy-forms==2.5",
   "crispy-bootstrap5==2025.6",
   "h11==0.16",
   "django-tastypie==0.15.1",
   "fudgeo==1.5.4",
+  "uvloop==0.22.1",
 ]
 
 [dependency-groups]

resource_tracking/workers.py

@@ -762,7 +762,7 @@ class DeviceStream(View):
     view_is_async = True
 
     async def stream(self, *args, **kwargs):
-        """Returns an iterator that queries and then yields tracking device data every n seconds."""
+        """Returns an iterator that runs forever, queries and then yields tracking device data every n seconds."""
         last_location = None
         device = None
 
@@ -803,7 +803,7 @@ async def stream(self, *args, **kwargs):
     async def get(self, request, *args, **kwargs):
         # Returns a streaming HTTP response that is consumed by the EventSource instance on the client.
         return StreamingHttpResponse(
-            self.stream(*args, **kwargs),
+            streaming_content=self.stream(*args, **kwargs),
             content_type="text/event-stream",
             headers={
                 # The Cache-Control header need to be set thus to work behind Fastly caching.