Constants§
- DEFAULT_
OUTPUT_ FILE_ BRIDGE - The const pointer the macro references.
- PROCESS_
ERROR_ FILE_ BRIDGE - We expose a CONST of type
BatchWorkflowProcessErrorFileFn, so passing&PROCESS_ERROR_FILE_BRIDGEexactly matches the trait’s needed function pointer type.
Functions§
- default_
output_ file_ bridge_ fn - A default bridging function, if the user doesn’t specify a particular T type.
We’ll parse each line as a
CamelCaseTokenWithCommentor whichever default type we prefer. - deserialize_
json_ with_ optional_ fields_ wrapper - Attempt to deserialize
json_valueintoT.
If the top‐level attempt fails, the function looks for a nested"fields"object and tries again.
All paths are heavily traced so we can see exactly where deserialization succeeds or fails. - handle_
failed_ json_ repair - handle_
finish_ reason_ length - handle_
successful_ response - process_
batch_ output_ and_ errors - We add
'static + Send + SynctoT, so that storing it in anArc<dyn ... + Send + Sync + 'static>is valid and the resultingFuturecan beSend. - process_
error_ data - process_
error_ file - This is the real async function that processes the error file for a given triple,using the list of error operations. Now uses NDJSON approach line by line.
- process_
output_ data - process_
output_ file - The core async function to process the output file for a given triple.Now we do NDJSON line-by-line parsing, just like the older batch-mode approach.
- process_
output_ file_ bridge_ fn - The bridging function EXACTLY matches the
BatchWorkflowProcessOutputFileFntype: - save_
failed_ entries