Commit 870cbdc8 by mohammed.shibili

corrections done

parent afe42478
from paho.mqtt import client as mqtt
from script.config.appconf import mqtt_broker, mqtt_port, mqtt_time
from script.logging.loggers import logger
......
import json
from script.core.handlers.mqtt_coo import mqtt_conn
from script.core.handlers.redis_connection import redis_connection
......@@ -20,7 +19,6 @@ class Consultancy:
Consultancy().doctors_list.append(f'KL/doctor{doctors}')
# publishing doctors list to redis
Consultancy().connection_redis.rpush("available_doctors", *Consultancy().doctors_list)
return Consultancy().doctors_list
@staticmethod
......@@ -40,7 +38,6 @@ class Consultancy:
if not topic:
topic = Consultancy().doctors_list[current_doctor]
# Increment the index for the next doctor
print(len(Consultancy().doctors_list))
Consultancy().connection_redis.set("current_doctor",
(current_doctor + 1) % len(Consultancy().doctors_list))
# Publish the patient information to the MQTT topic
......
Markdown is supported
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