Skip to content
This repository was archived by the owner on Nov 26, 2025. It is now read-only.
This repository was archived by the owner on Nov 26, 2025. It is now read-only.

implement task.apply #70

@felipao-mx

Description

@felipao-mx

make able to call tasks asynchronously as follows (based on Celery tasks apply function):

from fast_agave.tasks import task

# Task definition
@task(QUEUE_NAME=...)
async def my_task(message: Dict) -> None:
   ...


# task invocation

my_task.apply(dict(foo='bar'))

apply function should create a asyncio.Task and submit the the message to the queue associated in the task definition so we can do "fire and forget"

Metadata

Metadata

Assignees

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions