class MyHeavyProcessor:

	## this is a super costly operation
	def init():
		pass

	def _do_something( messages : list ) -> list:
		##
		pass


	def process( messages : list ) -> int:
		return self._do_something( messages )
		


@task( name='execute-heavy-processor' ):
def execute_processors( messages : list ):
	processor = MyHeavyProcessor()
	processor.init()
	return processor.process( messages )

@task( name = 'execute-something-else' )
def execute_something_else( message ):
	pass



@flow( name = 'my-flow' )
def my_flow():
	output = execute_processors( my_source.poll_messages() )

	for m in output:
		execute_something_else( m )

MyHeavyProcessor

MyHeavyProcessor