def _execute()

in osci/actions/process/generate_daily_osci_rankings.py [0:0]

• 16 lines of code
• 3 McCabe index (conditional complexity)

    def _execute(self, to_day: datetime):
        for date_period in [DatePeriodType.YTD, DatePeriodType.MTD]:
            osci_ranking_job = OSCIRankingJob(date_period_type=date_period)
            osci_commits_ranking_job = OSCICommitsRankingJob(date_period_type=date_period)

            commits = osci_ranking_job.extract(to_date=to_day).cache()

            osci_ranking_job.load(df=osci_ranking_job.transform(commits), date=to_day)
            osci_commits_ranking_job.load(df=osci_commits_ranking_job.transform(commits), date=to_day)

            if date_period == DatePeriodType.YTD:
                company_contributors_repos = CompanyContributorsRepositoryCommitsJob(date_period_type=date_period)
                company_contributors_repos.load(company_contributors_repos.transform(commits, date=to_day), date=to_day)

                osci_contributors_ranking_job = OSCIContributorsRankingJob(date_period_type=date_period)
                osci_contributors_ranking_job.load(osci_contributors_ranking_job.transform(commits), date=to_day)
                osci_language_job = OSCILanguagesJob(date_period_type=date_period)
                osci_language_job.load(osci_language_job.transform(commits), date=to_day)

                osci_licenses_ytd = OSCILicensesJob(date_period_type=date_period)
                osci_licenses_ytd.load(osci_licenses_ytd.transform(df=commits), date=to_day)