def get_daily_raw_push_events_commits()

in osci/datalake/base.py [0:0]

• 8 lines of code
• 4 McCabe index (conditional complexity)

    def get_daily_raw_push_events_commits(self, date: datetime) -> Iterator[Tuple[str, pd.DataFrame]]:
        for path in self.get_daily_raw_push_events_commits_paths(date=date):
            match = re.match(self.push_commits_filename_pattern, self._get_file_name(path))
            if match:
                company = match.group('company')
                df = self.get_raw_push_events_commits(path)
                if not df.empty:
                    yield company, df