EOX GitLab Instance

Commit f64dfbee authored by Fabian Schindler's avatar Fabian Schindler
Browse files

Fixing scheduler to send JSON

parent cb9d0a36
import logging
import redis
from time import sleep
import json
import schedule
......@@ -9,7 +10,7 @@ logger = logging.getLogger(__name__)
def trigger_queue(name: str, client: redis.Redis, queue: str):
logger.info(f"pushing {name} to {queue}")
client.lpush(queue, name)
client.lpush(queue, json.dumps({'name': name}))
def run_daemon(config: dict, host: str, port: int):
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment