Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

0.6.0 #1779

Draft
wants to merge 282 commits into
base: main
Choose a base branch
from
Draft

0.6.0 #1779

Changes from 1 commit
Commits
Show all changes
282 commits
Select commit Hold shift + click to select a range
35bc863
RabbitRouter asyncapi_version argument
KrySeyt Aug 2, 2024
8136d5e
tests fix
KrySeyt Aug 2, 2024
0e477fd
KafkaBroker asyncapi_version argument
KrySeyt Aug 2, 2024
80659cb
AsyncAPI Kafka fastapi tests
KrySeyt Aug 2, 2024
b1ae755
Confluent KafkaBroker asyncapi_version argument
KrySeyt Aug 2, 2024
319da09
Confluent fastapi tests
KrySeyt Aug 2, 2024
fcb4f34
Nats fastapi tests
KrySeyt Aug 2, 2024
676a454
RedisRouter asyncapi_version argument
KrySeyt Aug 2, 2024
c91a29b
Redis asyncapi fastapi tests
KrySeyt Aug 2, 2024
3af7078
RabbitMQ asyncapi test connection
KrySeyt Aug 2, 2024
1d769af
Kafka asyncapi connection test
KrySeyt Aug 3, 2024
ae9c4e6
Confluent asyncapi connection test
KrySeyt Aug 3, 2024
29c1804
Nats asyncapi connection test
KrySeyt Aug 3, 2024
aebada3
Redis asyncapi connection test
KrySeyt Aug 3, 2024
47d5c0a
RabbitMQ AsyncAPI security tests
KrySeyt Aug 3, 2024
889a66c
Kafka AsyncAPI security tests
KrySeyt Aug 3, 2024
62d6887
Confluent AsyncAPI security tests
KrySeyt Aug 3, 2024
b04315c
Redis AsyncAPI security tests
KrySeyt Aug 3, 2024
ed7d8d9
Nats AsyncAPI kv schema test
KrySeyt Aug 3, 2024
8e7e4e6
Nats AsyncAPI obj schema test
KrySeyt Aug 3, 2024
a839768
Test file structure update
KrySeyt Aug 3, 2024
f92dc6d
AsyncAPI 3.0.0 schemas files structure refactoring
KrySeyt Aug 3, 2024
d059c61
AsyncAPI 3.0.0 Kafka connection test fix
KrySeyt Aug 3, 2024
5028e26
AsyncAPI 3.0.0 tests fix
KrySeyt Aug 3, 2024
cf69dd4
AsyncAPI schemas refactoring
KrySeyt Sep 7, 2024
9fc11d6
Remove unneccessary TODO and reorder imports
KrySeyt Aug 6, 2024
3602f4f
AsyncAPI schema generations functions splitted by AsyncAPI version
KrySeyt Aug 6, 2024
4b60bf6
AsyncAPI schema splitting by versions
KrySeyt Sep 7, 2024
85da80f
Continue AsyncAPI schema splitting by version
KrySeyt Aug 8, 2024
0b4fef8
Channel specification
KrySeyt Aug 9, 2024
6e2978b
Broker dependency from AsyncAPI 2.6.0 to internal specs representation
KrySeyt Aug 9, 2024
59ead93
AsyncAPI 3.0.0 generation from internal specs
KrySeyt Aug 11, 2024
84a8bb8
mypy satisfied
KrySeyt Aug 11, 2024
238ddc4
lint.sh satisfied
KrySeyt Aug 11, 2024
6056ff5
Merge conflict fix
KrySeyt Aug 11, 2024
516c784
Cycle import fix
KrySeyt Aug 11, 2024
e324fb1
asyncapi base restructuring
KrySeyt Aug 13, 2024
e1ad476
specification restructuring
KrySeyt Aug 13, 2024
52db91f
refactoring
KrySeyt Sep 8, 2024
c31bc57
ruff satisfied
KrySeyt Aug 13, 2024
16c36be
fix
KrySeyt Sep 8, 2024
0968a74
SpecificationProto and Application moved to specification from asyncapi
KrySeyt Aug 13, 2024
9cc59d1
errors fix
KrySeyt Aug 13, 2024
ec7db29
comments fix
KrySeyt Aug 13, 2024
20b8d80
fix
KrySeyt Sep 8, 2024
7dc7447
fix
KrySeyt Sep 8, 2024
133ad05
replace AsyncAPI 2.6.0 components via internal specs
KrySeyt Aug 14, 2024
a22fa81
Components and servers in internal specs
KrySeyt Aug 15, 2024
5459359
Remove asyncapi attr from internal schema
KrySeyt Aug 15, 2024
ebc618a
I forgot what I done here but I done a lot of good things i think
KrySeyt Aug 15, 2024
e3e6297
AsyncAPI schema generation from specs refactoring - message
KrySeyt Aug 15, 2024
7bd26fe
Remove unused ServerBinding and more refactoring
KrySeyt Aug 16, 2024
75b1cd3
Bindings building from generate.py to schemas methods
KrySeyt Aug 16, 2024
954f677
AsyncAPI 2.6.0 general ChannelBinding building refactoring
KrySeyt Aug 16, 2024
d57297b
AsyncAPI 2.6.0 general OperationBinding building refactoring
KrySeyt Aug 16, 2024
2f4d220
Remove commented code
KrySeyt Aug 16, 2024
a3393d8
AsyncAPI license generation refactoring + little things
KrySeyt Aug 16, 2024
8308022
AsyncAPI contact generation refactoring + little things
KrySeyt Aug 16, 2024
a960394
AsyncAPI 2.6.0 Channel and Operation building refactoring
KrySeyt Aug 16, 2024
2cc8086
AsyncAPI 3.0.0 generation refactoring
KrySeyt Aug 16, 2024
c50f04a
refactoring
KrySeyt Aug 16, 2024
7719ca1
AsyncAPI 2.6.0 bindings refactoring
KrySeyt Aug 16, 2024
2d0b78d
AsyncAPI 2.6.0 bindings refactoring
KrySeyt Aug 16, 2024
ae428b4
AsyncAPI 3.0.0 operations building refactoring
KrySeyt Aug 16, 2024
9592cd1
AsyncAPI 3.0.0 channels building refactoring
KrySeyt Aug 16, 2024
1120c89
Names fix
KrySeyt Aug 16, 2024
1b4a7de
AsyncAPI server schema generation simplify
KrySeyt Aug 17, 2024
4fef981
AsyncAPI schema generation refactoring
KrySeyt Aug 17, 2024
4efccb3
AsyncAPI schema generation refactoring
KrySeyt Aug 17, 2024
71e16db
AsyncAPI schemas refactoring
KrySeyt Aug 17, 2024
74245e2
Documentation generation from AsyncAPI 3.0.0 support. Documentation s…
KrySeyt Aug 17, 2024
91f2bd9
Add asyncapi in docs CLI commands
KrySeyt Aug 17, 2024
15486d4
Tests update
KrySeyt Aug 17, 2024
b06f1e3
Tests update
KrySeyt Aug 17, 2024
8738774
Tests update
KrySeyt Aug 17, 2024
a01a6c2
CLI breaking changes revert
KrySeyt Aug 18, 2024
6c68603
AsyncAPI generation version choosing API changed
KrySeyt Aug 18, 2024
b4f7357
Add kerberos support for confluent broker (#1670)
kumaranvpl Aug 12, 2024
4439479
fix: support all RMQ exchanges in AsyncAPI (#1679)
Lancetnik Aug 13, 2024
6748d3f
Remove unused ignores (#1690)
kumaranvpl Aug 16, 2024
65fcfe2
Update package versions (#1702)
kumaranvpl Aug 20, 2024
94cdefb
feat: add broker.request method (#1649)
Lancetnik Aug 24, 2024
7489bde
Schema v3 and info v3
KrySeyt Jul 22, 2024
a06426d
AsyncAPI rabbit naming test
KrySeyt Jul 28, 2024
f7561cf
AsyncAPI schemas refactoring
KrySeyt Aug 4, 2024
5b46c8e
AsyncAPI generation refactoring
KrySeyt Aug 8, 2024
8937c9f
AsyncAPI 2.6.0 generation from internal specs
KrySeyt Aug 10, 2024
3c79d1a
mypy satisfied
KrySeyt Aug 11, 2024
230c910
refactoring
KrySeyt Aug 13, 2024
caff67f
fix
KrySeyt Sep 7, 2024
fbb0864
Tests update
KrySeyt Aug 17, 2024
93ec7ec
Confluent gssapi security schema test fix
KrySeyt Sep 6, 2024
ec4534c
fix
KrySeyt Sep 7, 2024
c0578b3
fix
KrySeyt Sep 7, 2024
08cce1c
fixes
KrySeyt Sep 7, 2024
b0314e1
fixes
KrySeyt Sep 8, 2024
c92d0f3
Ruff fixes
KrySeyt Sep 8, 2024
21a0d62
Fix kafka oauth test
KrySeyt Sep 8, 2024
94adc4e
Revert start_test_env.sh script docker compose update
KrySeyt Sep 8, 2024
5dd2f7c
docs: generate API References
KrySeyt Sep 8, 2024
531e268
Fix specification bindings amqp channel Exchange
KrySeyt Sep 8, 2024
697328a
Remove unused type: ignore comments
KrySeyt Sep 8, 2024
4e9cab7
type: ignore[override]
KrySeyt Sep 8, 2024
917f7cf
mypy satisfied
KrySeyt Sep 8, 2024
6111e53
mypy satisfied
KrySeyt Sep 8, 2024
da646d5
fixes
KrySeyt Sep 8, 2024
d8a21d9
rm debug statement
KrySeyt Sep 8, 2024
c48b3e1
fixes
KrySeyt Sep 8, 2024
9bb421f
remove unused code
KrySeyt Sep 8, 2024
ec2a962
Fix AsyncAPI 3.0.0 specs error
KrySeyt Sep 8, 2024
feaf2cc
Refactoring AsyncAPI specs generation
KrySeyt Sep 8, 2024
3eaf137
Fix AsyncAPI 3.0 tests
KrySeyt Sep 9, 2024
ffa76cb
Add oauth and gssapi AsyncAPI 3.0.0 tests for Kafka and Confluent
KrySeyt Sep 9, 2024
4cb0707
refactoring
KrySeyt Sep 9, 2024
2e1212e
refactoring
KrySeyt Sep 9, 2024
ceb80c6
refactoring
KrySeyt Sep 9, 2024
aae844b
fix
KrySeyt Sep 9, 2024
346a67a
Merge pull request #1624 from KrySeyt/add_asyncapi_v3_0_support
Lancetnik Sep 10, 2024
171064b
docs: generate API References
Lancetnik Sep 10, 2024
4842baa
chore: merge main
Lancetnik Sep 11, 2024
91405d9
Merge branch 'main' into 0.6.0
KrySeyt Sep 12, 2024
432b498
Merge pull request #1787 from KrySeyt/0.6.0
Lancetnik Sep 13, 2024
dc8deef
refactor: change project structura
Lancetnik Sep 13, 2024
6b638c7
lint: add ruff TID check
Lancetnik Sep 13, 2024
485c113
tests: use request instead of rpc publish everywhere
Lancetnik Sep 13, 2024
35fa776
refactor: remove NATS publish rpc
Lancetnik Sep 13, 2024
fba8e91
tests: polish requests tests
Lancetnik Sep 13, 2024
1662627
refactor: remove RMQ publish rpc
Lancetnik Sep 13, 2024
f551c21
refactor: remove Redis publish rpc
Lancetnik Sep 13, 2024
9996650
refactor: remove Kafka & Confluent publish rpc
Lancetnik Sep 13, 2024
0d90eba
Refactor AsyncAPI 2.6.0 generation / handling + fix wrong message title
KrySeyt Sep 13, 2024
1999eb8
AsyncAPI 3.0.0 generation / char in titles support
KrySeyt Sep 14, 2024
92f7f74
AsyncAPI generation / handling tests
KrySeyt Sep 14, 2024
c6e5bad
New tests refactoring
KrySeyt Sep 14, 2024
d7c6a75
docs: generate API References
KrySeyt Sep 14, 2024
07fb943
fix: correct AsyncAPI 2.6.0 channel names
Lancetnik Sep 16, 2024
7ea8db6
Merge pull request #1790 from KrySeyt/asyncapi_3.0.0_/_support
Lancetnik Sep 16, 2024
2a978c9
chore: merge main
Lancetnik Sep 16, 2024
5d4cac1
refactor: remove global broker from context
Lancetnik Sep 16, 2024
cc55a61
tests: fix all tests
Lancetnik Sep 17, 2024
0a6b83b
tests: refactor tests
Lancetnik Sep 18, 2024
865185e
logging fsm
Lancetnik Sep 20, 2024
2ac9c80
Feat: add process msg to broker.request methods (#1800)
Flosckow Sep 20, 2024
3a8665f
refactor: remove hash logic
Lancetnik Sep 23, 2024
cbae8bc
Merge branch 'main' into 0.6.0
Lancetnik Sep 23, 2024
51ee885
chore: merge main
Lancetnik Sep 24, 2024
996d8b1
Merge branch 'main' into 0.6.0
Lancetnik Sep 24, 2024
27a910d
refactor: reuse HAS_TYPER in CLI
Lancetnik Sep 25, 2024
d595de9
Merge branch '0.6.0' of github.com:airtai/faststream into 0.6.0
Lancetnik Sep 25, 2024
e2c89cd
Update specs public API (#1799)
KrySeyt Oct 1, 2024
199b3f4
refactor: change AsyncAPI inheritance tree
Lancetnik Oct 1, 2024
2ed00d7
lint: update ruff config, drop python3.8
Lancetnik Oct 2, 2024
6a38f00
chore: merge main
Lancetnik Oct 2, 2024
8c27d35
chore: merge main
Lancetnik Oct 10, 2024
50af9e3
add: NATS HowTO
Lancetnik Oct 10, 2024
e1c4d72
chore: merge main
Lancetnik Oct 17, 2024
aa6dc13
rm useless change
Lancetnik Oct 17, 2024
f63df92
refactor: create publisher factory
Lancetnik Oct 18, 2024
9a6461d
refactor: split publish to private
Lancetnik Oct 18, 2024
67ae2bf
chore: merge main
Lancetnik Oct 23, 2024
be596f0
refactor: use CMD to call publisher (#1857)
Lancetnik Oct 26, 2024
caa4cda
chore: merge main
Lancetnik Oct 28, 2024
5bbf7c8
chore: merge main
Lancetnik Oct 28, 2024
e39d0ad
Feat/fast depends 3 (#1886)
Lancetnik Oct 31, 2024
40d007b
Fixed RPC for Prometheus metrics (#1887)
roma-frolov Nov 1, 2024
0fa5fc1
tests on MetricsSettingsProvider for all brokers (#1890)
roma-frolov Nov 5, 2024
b5a123d
Merge branch 'main' into 0.6.0
Lancetnik Nov 5, 2024
0578c1b
feat/ack_middleware added middleware (#1869)
Rusich90 Nov 5, 2024
f54e5ee
refactor: use caps names for public enums
Lancetnik Nov 5, 2024
2a4c51d
refactor: little type changes
Lancetnik Nov 5, 2024
65ba4a4
refactor: new setup logic
Lancetnik Nov 6, 2024
cd87d8c
fix: correct RMQ subscriber get_one logic
Lancetnik Nov 6, 2024
af70c5b
Merge branch 'main' into 0.6.0
Lancetnik Nov 6, 2024
aa1562d
chore: fix pydantic 2.10 compatibility
Lancetnik Nov 7, 2024
4c14134
chore: merge main
Lancetnik Nov 7, 2024
362f6c9
refactor: create default middlewares in runtime
Lancetnik Nov 8, 2024
5211e43
Merge branch 'main' into 0.6.0
Lancetnik Nov 11, 2024
69f1985
refactor: add ack handling for brokers (#1897)
vectorvp Nov 12, 2024
736baba
feat: lazy decoder
Lancetnik Nov 13, 2024
9cf95c7
feat: added ack_first
Rusich90 Nov 14, 2024
d64f9f5
docs: generate API References
Rusich90 Nov 14, 2024
ad8d6b4
feat: ack_first added deprecated and docstrings to Ack_Policy
Rusich90 Nov 19, 2024
36da6ac
docs: generate API References
Rusich90 Nov 19, 2024
9b04fe8
chore: merge main
Lancetnik Nov 19, 2024
6c2d155
docs: fix typo
Lancetnik Nov 19, 2024
157151b
feat: ack_first refactored ack_first check
Rusich90 Nov 20, 2024
f22c2d5
refactor: new Specification Schema (#1843)
Lancetnik Nov 20, 2024
921ead8
fix: correct AsyncAPI 2.6 operations
Lancetnik Nov 20, 2024
181e862
tests: add Nats concurrent test
Lancetnik Nov 20, 2024
51f16eb
tests: actualize AsyncAPI 2.6.0 tests
Lancetnik Nov 20, 2024
7bd03af
fix: do not ack Nats Core message:
Lancetnik Nov 21, 2024
f269339
chore: merge main
Lancetnik Nov 22, 2024
cdeb2e8
chore: fix NATS Core acknowledgement
Lancetnik Nov 22, 2024
d1820fe
Remove `retry` from docs and add acknowledgement to getting start (#1…
sheldygg Nov 25, 2024
d81397a
tests: add middlewares enter-exit order test
Lancetnik Nov 25, 2024
08bb54d
Merge branch '0.6.0' of github.com:airtai/faststream into 0.6.0
Lancetnik Nov 25, 2024
898dd53
chore: merge 0.6
Lancetnik Nov 26, 2024
de1bca8
Merge branch 'Rusich90-feat/ack_first' into 0.6.0
Lancetnik Nov 26, 2024
d13624c
feat: added ack_first (#1917)
Rusich90 Nov 26, 2024
308dc50
Merge branch 'main' into 0.6.0
Lancetnik Nov 26, 2024
9456e7a
Fix AsyncAPI 3.0.0 AMQP bindings (#1949)
KrySeyt Dec 1, 2024
f8ab59d
docs: use DeliverPolicy Enum for deliver_policy in subscriber (#1952)
Majajashka Dec 1, 2024
65312e9
chore: merge main
Lancetnik Dec 3, 2024
1fd1039
chore: remove useless
Lancetnik Dec 3, 2024
af6f92f
lint: fix mypy a bit
Lancetnik Dec 4, 2024
7eb491c
chore: merge main
Lancetnik Dec 4, 2024
f010bd3
chore: remove useless code
Lancetnik Dec 4, 2024
4100bc0
chore: merge main
Lancetnik Dec 5, 2024
9e57990
tests: make cli tests little bit clear
Lancetnik Dec 5, 2024
31d913f
refactor: make BaseMiddleware generic
Lancetnik Dec 7, 2024
d490f41
Merge branch 'main' into 0.6.0
Lancetnik Dec 7, 2024
0bf4fc7
refactor: make Prometheus middleware generic
Lancetnik Dec 7, 2024
3af457d
Merge branch '0.6.0' of github.com:airtai/faststream into 0.6.0
Lancetnik Dec 7, 2024
9730784
refactor: make Telemetry middleware generic
Lancetnik Dec 7, 2024
00cce6a
refactor: deprecate subscriber/publisher-level middlewares
Lancetnik Dec 7, 2024
7b00966
refactor: deprecate filter middlewares
Lancetnik Dec 7, 2024
82e3969
tests: fix Kafka tests from main branch
Lancetnik Dec 9, 2024
baf6178
feat: init_routes added routes to init broker (#1981)
Rusich90 Dec 10, 2024
5f4c9f4
Fix: return logger (#1982)
Flosckow Dec 10, 2024
b9c7dd4
Feat: replace subscribers (#1976)
Flosckow Dec 10, 2024
a456e94
lint: fix routers types
Lancetnik Dec 11, 2024
a10d9b5
lint: fix internal broker types
Lancetnik Dec 11, 2024
4bf0e33
lint: fix ruff TC006
Lancetnik Dec 11, 2024
7025d86
lint: fix internal mypy
Lancetnik Dec 11, 2024
b84c032
feat: add application states (#1974)
Artem-Safronov Dec 12, 2024
cddf8de
fix: correct FastAPI with new state
Lancetnik Dec 12, 2024
c032ecf
tests: refactor publish js frame test
Lancetnik Dec 13, 2024
acf1d8c
feat: make return RecordMetada if not no_confirm, change annotations …
spataphore1337 Dec 14, 2024
d1a2376
fix type hins in faststream/specification (#1985)
IvanKirpichnikov Dec 15, 2024
d958655
chore: polish types
Lancetnik Dec 15, 2024
2bb82c2
lint: fix top-level mypy
Lancetnik Dec 15, 2024
c7f4bc3
lint: fix rabbit otel & prometheus mypy
Lancetnik Dec 15, 2024
195035e
lint: fix rabbit response types
Lancetnik Dec 15, 2024
a728ba7
feat: add raise BatchBufferOverflowException (#1989)
spataphore1337 Dec 16, 2024
5f9c7b6
fix: KeyError 'reply_to' in rabbit (#1999)
ApostolFet Dec 19, 2024
0b49d76
feat: delayed broker setting (#1931)
roma-frolov Dec 20, 2024
bc87327
lint: fix rabbit types a bit
Lancetnik Dec 20, 2024
f2bfb7c
Merge branch '0.6.0' of github.com:airtai/faststream into 0.6.0
Lancetnik Dec 20, 2024
bbea365
feat: Pretty prom tests (#2000)
roma-frolov Dec 23, 2024
ae50f1e
fix: correct PublishType for publisher decorator
Lancetnik Dec 25, 2024
094b7f4
Merge branch '0.6.0' of github.com:airtai/faststream into 0.6.0
Lancetnik Dec 25, 2024
8737347
Overwrite message schema (#2007)
ApostolFet Dec 25, 2024
a827df0
chore: merge main
Lancetnik Dec 26, 2024
2af8277
Merge branch '0.6.0' of github.com:airtai/faststream into 0.6.0
Lancetnik Dec 26, 2024
0694ef4
new test: in_memory_routing (#2010)
doublehomixide Dec 28, 2024
d482f7c
Merge branch 'main' into 0.6.0
Lancetnik Dec 28, 2024
18c166f
Separated thread for confluent kafka consumer client. (#2014)
DABND19 Dec 30, 2024
4f98e59
Feat: concurrent redis (#2012)
Flosckow Dec 30, 2024
e4d6e65
Merge branch 'main' into 0.6.0
Lancetnik Dec 30, 2024
5bced11
chore: add warning comment to confluent client
Lancetnik Dec 30, 2024
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
fix: correct FastAPI with new state
Lancetnik committed Dec 12, 2024

Verified

This commit was signed with the committer’s verified signature.
chybisov Eugene Chybisov
commit cddf8de1af84694d339b2f1408eb122f3ee91d2c
17 changes: 9 additions & 8 deletions faststream/_internal/application.py
Original file line number Diff line number Diff line change
@@ -16,9 +16,10 @@
from faststream._internal.constants import EMPTY
from faststream._internal.context import ContextRepo
from faststream._internal.log import logger
from faststream._internal.state import (
from faststream._internal.state import DIState
from faststream._internal.state.application import (
ApplicationState,
BasicApplicationState,
DIState,
RunningApplicationState,
)
from faststream._internal.state.broker import OuterBrokerState
@@ -103,7 +104,7 @@ def _init_setupable_( # noqa: PLW3201

serializer = PydanticSerializer()

self._state = BasicApplicationState(
self._state: ApplicationState = BasicApplicationState(
di_state=DIState(
use_fastdepends=True,
get_dependent=None,
@@ -171,6 +172,10 @@ def __init__(
else:
self.lifespan_context = fake_context

@property
def running(self) -> bool:
return self._state.running

@abstractmethod
def exit(self) -> None:
"""Stop application manually."""
@@ -278,7 +283,7 @@ async def _shutdown_logging(
"FastStream app shut down gracefully.",
)

# Setvice methods
# Service methods

def _log(self, level: int, message: str) -> None:
if self.logger is not None:
@@ -328,7 +333,3 @@ def after_shutdown(
apply_types(to_async(func), context__=self.context)
)
return func

@property
def running(self) -> bool:
return self._state.running
2 changes: 1 addition & 1 deletion faststream/_internal/fastapi/router.py
Original file line number Diff line number Diff line change
@@ -235,7 +235,7 @@ def wrapper(
response_model_exclude_defaults=response_model_exclude_defaults,
response_model_exclude_none=response_model_exclude_none,
provider_factory=self._get_dependencies_overides_provider,
state=self._state,
state=self._state.di_state,
)

return wrapper