gitea_admin/sientia-dataops-laborious_temporal
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

SIENTIAPDE-1094

Browse Source 
Update notification handler parameters and change task queue name
This commit is contained in:
vitor-aignosi
2025-06-10 08:39:19 -03:00
parent ce92fddbab
commit 17b98392a7
1 changed files with 1 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
laborious/worker/worker.py
View File

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