From 17b98392a7de434d6e9aff2e3078c955bcfe8817 Mon Sep 17 00:00:00 2001
From: vitor-aignosi <vitor.santos@aignosi.com.br>
Date: Tue, 10 Jun 2025 08:39:19 -0300
Subject: [PATCH] SIENTIAPDE-1094

Update notification handler parameters and change task queue name
---
 laborious/worker/worker.py | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

diff --git a/laborious/worker/worker.py b/laborious/worker/worker.py
index f10716e..ae5e47c 100644
--- a/laborious/worker/worker.py
+++ b/laborious/worker/worker.py
@@ -32,10 +32,6 @@ async def main():
         servers=os.getenv('KAFKA_BOOTSTRAP_SERVERS', 'http://localhost:9092'),
         logger=logger,
         project_name=os.getenv('PROJECT_NAME', 'laborious'),
-        pipeline_name='-',
-        trigger_name='-',
-        model_name='-',
-        model='-'
     )
 
     logger.info('Starting Activities...')
@@ -60,7 +56,7 @@ async def main():
     workers = [
         Worker(
             temporal_client,
-            task_queue='predictions-queue',
+            task_queue='predictions_batch-queue',
             workflows=[PredictionsBatch, PredictionProcess,
                        FormatAndExportPrediction],
             activities=[