Function execute_on_main_process

parallel/utils.py:23–30

(self, *args, **kwargs)

    """

    def execute_on_main_process(self, *args, **kwargs):
        if getattr(self, 'main_process_only', False):
            if is_main_process():
                return function(self, *args, **kwargs)
            else:
                return do_nothing(self, *args, **kwargs)
        else:
            return function(self, *args, **kwargs)

    return execute_on_main_process