Ë †Kàisãó¨—dZddlmZddlmZddlmZmZmZddl m Z m Z m Z ddl mZddlmZmZdd lmZed «Ze ZGd „d ee«Zdd „Zy)z,Functional dependencies: Depends and Shared.é)Ú annotations)ÚCallable)ÚAnyÚTypeVarÚcast)ÚDependencyFactoryÚSharedÚ SharedContext)Ú_Depends)Ú_parameter_cacheÚget_dependency_parametersé)Ú _TaskArgumentÚRcó —eZdZdZ dd„Zy)r z dict: # Access in-memory config, no I/O return {"api_url": "https://api.example.com", "timeout": 30} # Sync dependency - compute value from arguments def build_query_params( user_id: int = TaskArgument(), config: dict = Depends(get_config) ) -> dict: # Pure computation, no I/O return {"user_id": user_id, "timeout": config["timeout"]} # Async dependency - I/O operations async def get_user(user_id: int = TaskArgument()) -> User: # Network I/O - must be async return await fetch_user_from_api(user_id) # Async context manager - I/O resource management from contextlib import asynccontextmanager @asynccontextmanager async def get_db_connection(): # I/O operations - must be async conn = await db.connect() try: yield conn finally: await conn.close() @task async def my_task( params: dict = Depends(build_query_params), user: User = Depends(get_user), db: Connection = Depends(get_db_connection), ) -> None: await db.execute("UPDATE users SET ...", params) ``` )rrr )rs rÚDependsr(3s€ôx ””8˜JÓ'Ó (Ð(r&N)rzDependencyFactory[R]r r)r$Ú __future__rÚcollections.abcrÚtypingrrrÚ uncalled_forrr r Úuncalled_for.functionalr Ú_UncalledForDependsÚuncalled_for.introspectionr r Ú _contextualrrÚDependencyFunctionr(r%r&rúr2sTðÙ2å"å$ß%Ñ%÷ñõ D÷ õ 'á ˆCƒL€à&ÐôÐ" 1Ñ%ôô(<)r&