def METHOD_NAME(sql_obs, sample_run, session, tmpfile):
    sql_obs2 = SqlObserver.create_from(sql_obs.engine, session)
    sample_run["_id"] = None
    sample_run["ex_info"]["sources"] = [[tmpfile.name, tmpfile.md5sum]]
    sql_obs.started_event(**sample_run)
    sql_obs2.started_event(**sample_run)
    assert session.query(Run).count() == 2
    assert session.query(Source).count() == 1