parent
742a1b1bc2
commit
cc7bf02c93
|
@ -118,10 +118,7 @@ def mqtt_publisher(ti_queue):
|
||||||
while True:
|
while True:
|
||||||
try:
|
try:
|
||||||
try:
|
try:
|
||||||
start = time.time()
|
|
||||||
tube_index = ti_queue.get(block=False)
|
tube_index = ti_queue.get(block=False)
|
||||||
end = time.time()
|
|
||||||
print("Receiving of tube index took: "+str(end-start))
|
|
||||||
tube_index_old = tube_index
|
tube_index_old = tube_index
|
||||||
except Empty:
|
except Empty:
|
||||||
if tube_index_old is not None:
|
if tube_index_old is not None:
|
||||||
|
|
Loading…
Reference in New Issue