async def METHOD_NAME(self, run_query, flow_run_id):
    logs = [dict(flow_run_id=flow_run_id, message="test") for _ in range(10)]
    result = await run_query(
        query=self.mutation,
        variables=dict(input=dict(logs=logs)),
    )
    assert result.data.write_run_logs.success
    await asyncio.sleep(0.5)
    logs = await models.Log.where({"flow_run_id": {"_eq": flow_run_id}}).get(
        {"message", "task_run_id"}
    )
    assert len(logs) == 10
    assert all(log.message == "test" for log in logs)
    assert all(log.task_run_id is None for log in logs)