Method is_main_process

workers/base.py:160–161

(self)

        if self.is_main_process:
            self.writer = open(output_pth, "w", encoding='utf-8')
    def is_main_process(self):
        return self.accelerator.is_main_process
    def print_in_main(self, *args, **kwargs):
        if self.is_main_process:
            print(*args, **kwargs)