refactor code according to comments

app.py

@@ -1,21 +1,28 @@
+import logging
 from flask import Flask
 from flask_apscheduler import APScheduler
-from routes import bp
+from asgiref.wsgi import WsgiToAsgi
+
+from routes.main import bp
 from main import main as data_collection_main
 
 class Config:
-    SCHEDULER_API_ENABLED = True  # Enables the scheduler's API (optional, can be used for debugging)
+    SCHEDULER_API_ENABLED = True  # Enables the scheduler's API
 
 def create_app():
     # Create the Flask application
-    app = Flask(__name__)
+    flask_app = Flask(__name__)
     
     # Load config for APScheduler
-    app.config.from_object(Config())
+    flask_app.config.from_object(Config())
     
-    # Register our Blueprint (imported from routes.py)
-    app.register_blueprint(bp)
+    # Register our Blueprint 
+    flask_app.register_blueprint(bp)
     
+    logging.basicConfig(
+        format='%(asctime)s - %(levelname)s - %(funcName)s - %(message)s')
+    logging.getLogger().setLevel(logging.ERROR)
+
     # Initialize the APScheduler
     scheduler = APScheduler()
     scheduler.init_app(app)
@@ -34,7 +41,10 @@ def create_app():
     
     return app
 
+app = create_app()
+
+asgi_app = WsgiToAsgi(app)
+
 if __name__ == '__main__':
     # Create the Flask app and run it
-    app = create_app()
-    app.run(debug=True, port=5000)
+   app.run()

requirements.txt

@@ -196,5 +196,6 @@ wrapt==1.16.0
 yarl==1.9.4
 prefect==2.20.2
 pycryptodome==3.21.0
+asgiref==3.8.1
 flask
-flask_apscheduler
+flask_apscheduler

routes/__init__.py

@@ -0,0 +1,6 @@
+"""
+This module sets up the main Blueprint for the Flask application.
+"""
+from flask import Blueprint
+
+bp = Blueprint("data", __name__)

routes.py → routes/main.py

@@ -1,7 +1,7 @@
 from flask import Blueprint, jsonify
-from main import main as data_collection_main
+from main import main as data_collection
 
-bp = Blueprint('data_routes', __name__)
+from . import bp
 
 @bp.route('/trigger-data-collection', methods=['GET'])
 def trigger_data_collection():
@@ -10,5 +10,5 @@ def trigger_data_collection():
     
     HTTP Method: GET (you can switch to POST if you prefer).
     """
-    data_collection_main()  # This calls the Prefect flow that orchestrates data collection
+    data_collection()  # This calls the Prefect flow that orchestrates data collection
     return jsonify({"message": "Data collection triggered successfully"}), 200