Update task_runner.py

try flushing logs to see if docker can catch them sooner

task_runner.py

@@ -27,10 +27,10 @@ def fetch_keys():
         # Decrypt each key before returning
         keys = [cipher.decrypt(row[0]).decode() for row in cursor.fetchall()]
         conn.close()
-        print(f"Fetched and decrypted {len(keys)} keys from the database.")
+        print(f"Fetched and decrypted {len(keys)} keys from the database.", flush=True)
         return keys
     except Exception as e:
-        print(f"Error fetching keys: {e}")
+        print(f"Error fetching keys: {e}", flush=True)
         return []
 
 def send_request(token):
@@ -39,16 +39,17 @@ def send_request(token):
     try:
         response = requests.get(url)
         masked_token = mask_token(token)
-        print(f"Request to {masked_token} returned status code {response.status_code}.")
+        print(f"Request to {masked_token} returned status code {response.status_code}.", flush=True)
     except requests.RequestException as e:
-        print(f"Failed to send request for token {mask_token(token)}: {e}")
+        print(f"Failed to send request for token {mask_token(token)}: {e}", flush=True)
 
 if __name__ == "__main__":
+    print("Starting task_runner...", flush=True)
     while True:
         keys = fetch_keys()
         if not keys:
-            print("No keys found in the database.")
+            print("No keys found in the database.", flush=True)
         for key in keys:
             send_request(key)
-        print(f"Sleeping for {interval} seconds.")
+        print(f"Sleeping for {interval} seconds.", flush=True)
         time.sleep(interval)