public void registerTaskDefs ( List < TaskDef > taskDefs ) { Preconditions . checkNotNull ( taskDefs , "Task defs list cannot be null" ) ; stub . createTasks ( MetadataServicePb . CreateTasksRequest . newBuilder ( ) . addAllDefs ( taskDefs . stream ( ) . map ( protoMapper :: toProto ) :: iterator ) . build ( ) ) ; }
Registers a list of task types with the conductor server