@task(log_stdout=True)
def db_connection(credentials: dict) -> any:
    import sqlalchemy as db
    ssl_args = {args}
    user = credentials['username']
    password = credentials['password']
    url = 'Our URL'
    port = 1111
    engine = db.create_engine(
        f'mysql://{user}:{password}@{url}:{port}/?charset=utf8', 
        connect_args=ssl_args
    )
    return engine

db.create_engine