diff --git a/scouter/worker/worker.py b/scouter/worker/worker.py index 818d129..74ad479 100644 --- a/scouter/worker/worker.py +++ b/scouter/worker/worker.py @@ -70,6 +70,9 @@ async def main(): task_queue='scouter-queue', workflows=[Scouter, CoreScouter], activities=[ + activities.load_latest_data, + activities.get_last_data_timestamp, + activities.put_last_data_timestamp, activities.load_from_kafka, activities.data_quality_gate, activities.aggregate_data,