import os os.environ["USE_MOCK"] = "true" # Set to false if using real tweets or local kafka from dashboard import *