async def METHOD_NAME(tmp_path, event_loop):
    test_notebook = "tests/demo/demo_scheduler.ipynb"
    cur_path = os.path.join(os.getcwd(), test_notebook)
    new_path = os.path.join(tmp_path, test_notebook)
    os.makedirs(os.path.dirname(new_path))
    logger = Logger()
    notebooks = Notebooks(logger)
    jobs = Jobs(logger, True, [])
    scheduler = Scheduler(logger, jobs, notebooks, event_loop)
    uid = str(uuid.uuid4())
    copy2(cur_path, new_path)
    recur = "* * * * *"
    job = {
        "type": t_scheduler,
        "path": new_path,
        "params": {},
        "value": recur,
        "status": t_add,
    }
    await jobs.update(
        uid,
        job["path"],
        job["type"],
        job["value"],
        job["params"],
        job["status"],
    )
    resp_json = await jobs.list(uid)
    assert len(resp_json) == 1
    res_job = resp_json[0]
    assert res_job.get("type") == t_scheduler
    assert res_job.get("path") == new_path
    assert res_job.get("value") == recur
    assert res_job.get("status") == t_add
    await scheduler.start(test_mode=True)
    resp_json = await jobs.list(uid)
    assert len(resp_json) == 1
    res_job = resp_json[0]
    assert res_job.get("type") == t_scheduler
    assert res_job.get("path") == new_path
    assert res_job.get("value") == recur
    assert res_job.get("status") == t_health
    # list_out_in_prod = scheduler.list_output(new_path)
    # assert len(list_out_in_prod) == 1
    # histo = list_out_in_prod.to_dict("records")[0]
    # scheduler.get_output(new_path, histo.get("timestamp"))
    # filename = os.path.basename(new_path)
    # out_filename = f"{histo.get('timestamp')}___{t_output}__{filename}"
    # dirname = os.path.dirname(new_path)
    # new_path_out_histo = os.path.join(
    #     dirname, out_filename
    # )
    # assert os.path.isfile(new_path_out_histo)