Closed anovv closed 5 months ago
Each operator should implement schema() which defines output messages schema based on input schemas at job graph compilation time
schema()
Each operator should implement
schema()
which defines output messages schema based on input schemas at job graph compilation time