from threading import Thread
import requests
-from consumer.base import BaseConsumer
+from doctor_tests.consumer.base import BaseConsumer
class SampleConsumer(BaseConsumer):
func()
return 'consumer app shutting down...'
- app.run(host="0.0.0.0", port=self.port)
\ No newline at end of file
+ app.run(host="0.0.0.0", port=self.port)