Compare commits
2
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
63975169c0 | ||
|
|
387986e2d8 |
+1
-1
@@ -25,7 +25,7 @@ def connect(
|
|||||||
# load environment variables
|
# load environment variables
|
||||||
load_dotenv()
|
load_dotenv()
|
||||||
ip_addr = os.getenv(
|
ip_addr = os.getenv(
|
||||||
'DB_IP_ADDRESS',
|
'DB_IP_ADDRESS',
|
||||||
default=DB_IP_ADDRESS
|
default=DB_IP_ADDRESS
|
||||||
)
|
)
|
||||||
db_name = os.getenv(
|
db_name = os.getenv(
|
||||||
|
|||||||
@@ -27,7 +27,11 @@ def initialise_app(
|
|||||||
"""
|
"""
|
||||||
# load environment variables
|
# load environment variables
|
||||||
load_dotenv()
|
load_dotenv()
|
||||||
assert 'USER_ID' in os.environ, 'environment variable USER_ID must be specified'
|
assert (
|
||||||
|
'USER_ID' in os.environ
|
||||||
|
), (
|
||||||
|
'environment variable USER_ID must be specified'
|
||||||
|
)
|
||||||
logger_level = os.getenv(
|
logger_level = os.getenv(
|
||||||
'LOGGER_LEVEL',
|
'LOGGER_LEVEL',
|
||||||
default=LOGGER_LEVEL
|
default=LOGGER_LEVEL
|
||||||
@@ -63,5 +67,5 @@ def initialise_app(
|
|||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
user_id = initialise_app()
|
initialise_app()
|
||||||
logging.warning('test message')
|
logging.warning('test message')
|
||||||
|
|||||||
+1
-1
@@ -123,7 +123,7 @@ if __name__ == '__main__':
|
|||||||
)
|
)
|
||||||
# extra data flush
|
# extra data flush
|
||||||
if (
|
if (
|
||||||
time.time() >= data_flush_time and
|
time.time() >= data_flush_time and
|
||||||
data_queue.qsize() > 0
|
data_queue.qsize() > 0
|
||||||
):
|
):
|
||||||
logging.debug('triggered extra data flush')
|
logging.debug('triggered extra data flush')
|
||||||
|
|||||||
Reference in New Issue
Block a user