celery.py

# providers.py
def provide_dao() -> SomeDAO:
    return SomeDAO()
  
  
def provide_service(dao_provider: Callable([], SomeDAO)) -> Service:
    return Service(dao=dao_provider())
  
  
# tasks.py
def some_task(service_provider: Callable[[], Service]) -> None:
    service = service_provider()
    service.calling_some_method()
    

# celery.py
from functools import partial


def build_celery() -> Celery:
    app = Celery()
    
    nodepends_provide_service = partial(provide_service, dao_provider=provide_dao)
    
    nodepends_some_task = partial(some_task, service_provider=nodepends_provide_service)
    app.registry.add_task(nodepends_some_task)
    
    return app