async def METHOD_NAME(tenant_id, flow_run_id, task_run_id):
    where_clause = {
        "tenant_id": {"_eq": tenant_id},
        "flow_run_id": {"_eq": flow_run_id},
        "task_run_id": {"_eq": task_run_id},
    }
    logs_count = await models.Log.where(where_clause).count()
    await api.logs.create_logs(
        [
            dict(
                tenant_id=tenant_id,
                flow_run_id=flow_run_id,
                task_run_id=task_run_id,
            )
        ]
    )
    assert await models.Log.where(where_clause).count() == logs_count + 1
    log = await models.Log.where(where_clause).first({"task_run_id"})
    assert log.task_run_id == task_run_id