ccflow_celery.tasks

Functions

execute_model_task(→ dict)

Execute a ccflow CallableModel on a Celery worker.

Module Contents

ccflow_celery.tasks.execute_model_task(model_class: str, model_config: dict, context_class: str, context_config: dict) → dict

Execute a ccflow CallableModel on a Celery worker.

This is the Celery task function that reconstructs a model and context from their serialized configurations and executes the model.

Parameters:

• model_class – Fully qualified class name (e.g., “ccflow_s3.S3Model”)

• model_config – Dict of model configuration (pydantic model_dump)

• context_class – Fully qualified class name for the context

• context_config – Dict of context configuration (pydantic model_dump)

Returns:

Dict representation of the result (model_dump)