Diff Coverage

Diff: origin/master...HEAD, staged and unstaged changes

Source File Diff Coverage (%) Missing Lines
hyper_parallel/trainer/base.py 60.0% 801,975
hyper_parallel/trainer/callbacks/base.py 91.7% 489
hyper_parallel/trainer/base.py
797
798
799
800
801
802
803
804
805
        self.tensorboard_callback.on_train_begin(self.state)
        # Checkpoint runs after log writers are armed and before progress so
        # resumed ``global_step`` is reflected in the tqdm initial position.
        self.checkpoint_callback.on_train_begin(self.state)
        self.progress_callback.on_train_begin(self.state)
        for cb in self.user_callbacks:
            cb.on_train_begin(self.state)

    def on_train_end(self):
971
972
973
974
975
976
977
978
979
        # actually trained.
        micro_batches = next(data_iterator)
        prepare_batch_fn = getattr(self.spec, "prepare_batch_fn", None)
        if prepare_batch_fn is not None:
            micro_batches = [
                prepare_batch_fn(batch, self.model)
                for batch in micro_batches
            ]
        self.state.global_step += 1
hyper_parallel/trainer/callbacks/base.py
485
486
487
488
489
490
491
492
493
        super().__init__(trainer)
        train_cfg = getattr(trainer.args, 'train', None)
        ckpt_cfg = getattr(train_cfg, 'checkpoint', None)
        if ckpt_cfg is None:
            ckpt_cfg = getattr(trainer.args, 'checkpoint', None)
        self.enabled = getattr(ckpt_cfg, 'save_hf_weights', False) if ckpt_cfg else False
        self.save_steps = getattr(ckpt_cfg, 'save_steps', 0) if ckpt_cfg else 0
        self.output_dir = getattr(ckpt_cfg, 'output_dir', 'outputs') if ckpt_cfg else 'outputs'
        self._last_saved_step = -1