(
&self,
py: Python<'_>,
lane: &str,
mode: &str,
timeout_ms: u64,
)
| 2329 | /// timeout_ms: Timeout for external processing in milliseconds (default 60000). |
| 2330 | #[pyo3(signature = (lane, mode="internal", timeout_ms=60000))] |
| 2331 | fn set_lane_handler( |
| 2332 | &self, |
| 2333 | py: Python<'_>, |
| 2334 | lane: &str, |
| 2335 | mode: &str, |
| 2336 | timeout_ms: u64, |
| 2337 | ) -> PyResult<()> { |
| 2338 | let lane = parse_lane(lane)?; |
| 2339 | let mode = parse_handler_mode(mode)?; |
| 2340 | let config = RustLaneHandlerConfig { mode, timeout_ms }; |
| 2341 | let session = self.inner.clone(); |
| 2342 | py.allow_threads(move || get_runtime().block_on(session.set_lane_handler(lane, config))); |
| 2343 | Ok(()) |
| 2344 | } |
| 2345 | |
| 2346 | /// Complete an external queue task by ID. |
| 2347 | /// |
nothing calls this directly
no test coverage detected