Celery Tasks

kafkastreamer.tasks.refresh(models: Sequence[str] | None = None, source: str | None = None) → dict[str, Any][source]: Does full refresh for specified models or all registered models.

kafkastreamer.tasks.refresh_model(model_name: str, source: str | None = None) → dict[str, Any][source]: Does full refresh for specified model.