This commit is contained in:
parent
1acdd6d21c
commit
c5500012ce
@ -1,4 +1,6 @@
|
|||||||
#!/usr/bin/env python3
|
#!/usr/bin/env python3
|
||||||
|
import time
|
||||||
|
|
||||||
import jaeger_client
|
import jaeger_client
|
||||||
import opentracing
|
import opentracing
|
||||||
|
|
||||||
@ -89,6 +91,9 @@ def main():
|
|||||||
logging.info("SIGINT Received! Stopping stuff...")
|
logging.info("SIGINT Received! Stopping stuff...")
|
||||||
channel.stop_consuming()
|
channel.stop_consuming()
|
||||||
|
|
||||||
|
time.sleep(2) # lol
|
||||||
|
opentracing.tracer.close()
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
main()
|
main()
|
||||||
|
Loading…
Reference in New Issue
Block a user