async def METHOD_NAME(flow_run_id, tenant_id):
    where_clause = {
        "tenant_id": {"_eq": tenant_id},
        "flow_run_id": {"_eq": flow_run_id},
    }
    logs_count = await models.Log.where(where_clause).count()
    dt = pendulum.now()
    await api.logs.create_logs([dict(tenant_id=tenant_id, flow_run_id=flow_run_id)])
    assert await models.Log.where(where_clause).count() == logs_count + 1
    log = await models.Log.where(where_clause).first(
        {"timestamp", "level", "task_run_id"}
    )
    assert log.timestamp > dt
    assert log.level == "INFO"
    assert log.task_run_id is None