Boilerplate Code for Batch Processing Block
Following code is the least required code to write a Block that processes in Batch mode.
# This is done for only one instance to to exist
from pipelineblocksdk.api.Singleton import Singleton
from pipelineblocksdk.construct.base.BatchBlock import BatchBlock
# Following code is the definition for a batch block
class MyBlock(BatchBlock, Singleton):
# This is the entrypoint for the block. This is a mandatory function.
def run(self):
#Your code goes here
print('Run function says: Hello, world!')
output_dict = dict()
return output_dict