Task Summary
Region (amber/src/main/scala/org/apache/texera/amber/engine/architecture/scheduling/Region.scala) is the unit of execution for the workflow scheduler but currently has no dedicated unit tests. Add RegionSpec covering its public surface:
- Constructor exposes
physicalOps, physicalLinks, and ports via getOperators/getLinks/getPorts
getOperator(id) looks up by PhysicalOpIdentity and throws NoSuchElementException for unknown idstopologicalIterator yields operators in topological order derived from physicalLinksgetSourceOperators treats operators without input ports as sourcesgetStarterOperators equals getSourceOperators when no resourceConfig is provided
Priority
P3 – Low
Task Type
Task Summary
Region(amber/src/main/scala/org/apache/texera/amber/engine/architecture/scheduling/Region.scala) is the unit of execution for the workflow scheduler but currently has no dedicated unit tests. AddRegionSpeccovering its public surface:physicalOps,physicalLinks, andportsviagetOperators/getLinks/getPortsgetOperator(id)looks up byPhysicalOpIdentityand throwsNoSuchElementExceptionfor unknown idstopologicalIteratoryields operators in topological order derived fromphysicalLinksgetSourceOperatorstreats operators without input ports as sourcesgetStarterOperatorsequalsgetSourceOperatorswhen noresourceConfigis providedPriority
P3 – Low
Task Type