main.py
def start_bundle(self):
        """Called before a bundle of elements is processed on a worker.

        Elements to be processed are split into bundles and distributed
        to workers. Before a worker calls process() on the first element
        of its bundle, it calls this method.
        """
        if not hasattr(self, 'tagger'):
            self.init_tagger()
Called before a bundle of elements is processed on a worker.

        Elements to be processed are split into bundles and distributed
        to workers. Before a worker calls process() on the first element
        of its bundle, it calls this method.
        
Called before a bundle of elements is processed on a worker.
Elements to be processed are split into bundles and distributed
to workers. Before a worker calls process() on the first element
of its bundle, it calls this method.
Called before a bundle of elements is processed on a worker . Elements to be processed are split into bundles and distributed to workers . Before a worker calls process () on the first element of its bundle it calls this method .
def start_bundle(self):
        if not hasattr(self, 'tagger'):
            self.init_tagger()
def start_bundle ( self ) : if not hasattr ( self , 'tagger' ) : self . init_tagger ( )
Called before a bundle of elements is processed on a worker.
Called before a bundle of elements is processed on a worker .
"""Called before a bundle of elements is processed on a worker.

        Elements to be processed are split into bundles and distributed
        to workers. Before a worker calls process() on the first element
        of its bundle, it calls this method.
        """
self