search

taskiq-python / taskiq

Distributed task queue with full async support
MIT License
872 stars 53 forks source link

fix: sync decorators #343

Open Sobes76rus opened 4 months ago

Sobes76rus commented 4 months ago

use case

@broker.task()
@validate_call()
async def task(arg1: str) -> None: ...

so, the thing is that pydantic's validator_call is syncronious decorator which returns awaitable future after call right now receiver can't work with sync decorators on async functions

Sobes76rus commented 3 months ago

@s3rius all done as you suggested