parent
86352b5bd3
commit
b93d0d7d2e
|
@ -158,7 +158,7 @@ def start_mqtt_publishers(universe_count):
|
||||||
print(str(universes_to_publish))
|
print(str(universes_to_publish))
|
||||||
for universe in universes_to_publish:
|
for universe in universes_to_publish:
|
||||||
print(str(universe))
|
print(str(universe))
|
||||||
threads = [threading.Thread(target=mqtt_publisher, args=(int(universe),))]
|
threads = [threading.Thread(target=mqtt_publisher, args=(universe,))]
|
||||||
|
|
||||||
for thread in threads:
|
for thread in threads:
|
||||||
thread.start()
|
thread.start()
|
||||||
|
|
Loading…
Reference in New Issue