from app.core.logger import make_log from app.core.storage import db_session import asyncio async def main(): make_log("Uploader", "Service started", level="info") while True: # make_log("Uploader", "Service running", level="debug") # with db_session() as session: # for stored_content in session.query(StoredContent).filter(StoredContent.uploaded == False).all(): # pass await asyncio.sleep(5) if __name__ == '__main__': loop = asyncio.get_event_loop() loop.run_until_complete(main()) loop.close()