added separate flush interval #13

Merged
brian merged 14 commits from main into release 2023-07-12 14:16:03 +02:00
3 changed files with 7 additions and 3 deletions
Showing only changes of commit 387986e2d8 - Show all commits
+1 -1
View File
@@ -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(
+5 -1
View File
@@ -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
+1 -1
View File
@@ -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')