INNER CODE UNIT · Python

JobCreate

bunkeriot/BunkerM · backend/app/agent-api/main.py:327

class JobCreate(BaseModel):
    description: str
    cron: str
    topic: str
    payload: str
    qos: int = 0
    retain: bool = False


def _publish_and_record(topic: str, payload: str, qos: int, retain: bool, job_id: str):
    try:
        mqtt_publish.single(
            topic=topic, payload=payload, qos=qos, retain=retain,
            hostname=MQTT_HOST, port=MQTT_PORT,
            auth={"username": MQTT_USER, "password": MQTT_PASS},
        )
        logger.info(f"Scheduler job {job_id} fired: {topic} = {payload[:60]}")
        with _lock:

View source record →