From 429345e8d268422c351bd0d334530d88f01206c1 Mon Sep 17 00:00:00 2001 From: Pavel Kirilin Date: Thu, 13 Nov 2025 09:45:36 +0100 Subject: [PATCH] Fixed shared state among all tasks. --- taskiq_fastapi/initializator.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/taskiq_fastapi/initializator.py b/taskiq_fastapi/initializator.py index f31a6f0..102739b 100644 --- a/taskiq_fastapi/initializator.py +++ b/taskiq_fastapi/initializator.py @@ -1,3 +1,4 @@ +import copy from typing import Any, Awaitable, Callable, Mapping, Optional, Union from fastapi import FastAPI, Request @@ -112,10 +113,10 @@ def populate_dependency_context( broker.dependency_overrides.update( { Request: lambda: Request( - scope={"app": app, "type": "http", "state": asgi_state}, + scope={"app": app, "type": "http", "state": copy.copy(asgi_state)}, ), HTTPConnection: lambda: HTTPConnection( - scope={"app": app, "type": "http", "state": asgi_state}, + scope={"app": app, "type": "http", "state": copy.copy(asgi_state)}, ), }, )