async def METHOD_NAME(self, run_query, flow_run_id, task_run_id):
    logs = [
        dict(flow_run_id=flow_run_id, task_run_id=task_run_id, message="test")
        for _ in range(14)
    ]
    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({"task_run_id": {"_eq": task_run_id}}).get(
        {"message"}
    )
    assert len(logs) == 14
    assert all(log.message == "test" for log in logs)