etl.py

from hamilton import driver

dr = driver.Driver(
    {"mode": "batch"},
    aggregations, data_loaders, joins, features, model
)
inputs = {
    "client_login_db": "login_data",
    "client_login_table": "client_logins",
    "survey_results_db": "survey_data",
    "survey_results_table": "survey_results",
    "execution_time": datetime.datetime.now(),
}
df = dr.execute(["predictions"], inputs=inputs)
# Do something with the results