async def METHOD_NAME(self, run_query, flow_run_id):
    result = await run_query(
        query=self.mutation,
        variables=dict(
            input=dict(
                logs=[
                    dict(flow_run_id=flow_run_id, message="test", level="bad-level")
                ]
            )
        ),
    )
    assert "got invalid value 'bad-level'" in result.errors[0].message