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=[