Added task generator structure

This commit is contained in:
Lorenzo Venerandi
2025-01-29 00:44:42 +01:00
parent 8444fcd1fc
commit 1e3109d901
2 changed files with 40 additions and 11 deletions

View File

@@ -0,0 +1,28 @@
import logging
def handle_task(task, output_dir):
try:
match task['type']:
case 'producer_nats':
__generate_producer(task, output_dir)
case 'processor_nats':
__generate_processor(task, output_dir)
case 'dbsync_nats':
__generate_dbsync(task, output_dir)
case _:
logging.error(f"Task type {task['type']} not supported")
pass
except KeyError as e:
logging.error(f"Error parsing task: {e}")
pass
def __generate_producer(task, output_dir):
pass
def __generate_processor(task, output_dir):
pass
def __generate_dbsync(task, output_dir):
pass