a0d7b41274350f55250859e13fce5718156f93cc,tests/test_worker.py,,get_new_worker,#,107

Before Change

    dataset_conf.train_path = os.path.join(
        os.path.join(os.path.join(PROJECT_ROOT, "data"), "test"), "pollution_1.csv")

    db = Database(**sql_conf.to_dict())
    atm = ATM(sql_conf=sql_conf)

    datarun = atm.enter_data(dataset_conf, run_conf)
    // datarun = db.get_datarun(run_id.id)

After Change

    dataset_conf = DatasetConfig(kwargs)
    dataset_conf.train_path = POLLUTION_PATH

    db = Database(dialect="sqlite", database=DB_PATH)
    atm = ATM(dialect="sqlite", database=DB_PATH)

    dataset = atm.add_dataset(**dataset_conf.to_dict())
    run_conf.dataset_id = dataset.id

Instances