Task Summary
common/workflow-compiler/src/main/scala/org/apache/texera/common/compiler/WorkflowCompiler.scala checks every Python-based physical operator's generated code for the #EXCEPTION DURING CODE GENERATION: marker that PythonOperatorDescriptor embeds when an operator's generatePythonCode throws. When the marker is found, the compiler either appends a RuntimeException("Operator is not configured properly: ...") to the caller's error list or throws it immediately when no error list is provided.
WorkflowCompilerSpec (15 tests) never exercises this branch on the consumer side; the only test of the marker is the producer-side PythonOperatorDescriptorSpec, which asserts that the marker is written but not that the compiler reacts to it. Both the error-list and the throwing branches are unasserted.
Task Type
Task Summary
common/workflow-compiler/src/main/scala/org/apache/texera/common/compiler/WorkflowCompiler.scalachecks every Python-based physical operator's generated code for the#EXCEPTION DURING CODE GENERATION:marker thatPythonOperatorDescriptorembeds when an operator'sgeneratePythonCodethrows. When the marker is found, the compiler either appends aRuntimeException("Operator is not configured properly: ...")to the caller's error list or throws it immediately when no error list is provided.WorkflowCompilerSpec(15 tests) never exercises this branch on the consumer side; the only test of the marker is the producer-sidePythonOperatorDescriptorSpec, which asserts that the marker is written but not that the compiler reacts to it. Both the error-list and the throwing branches are unasserted.Task Type