def transform()

in osci/jobs/osci_ranking.py [0:0]

• 14 lines of code
• 1 McCabe index (conditional complexity)

    def transform(self, df: DataFrame, **kwargs) -> DataFrame:
        report_schema = self.report_cls.schema
        thresholds = [
            CommitsThresholds(col=report_schema.total, threshold=1),
            CommitsThresholds(col=report_schema.active, threshold=10)
        ]
        return get_companies_employees_activity_rank_combined(df=df,
                                                              commits_id_field=self.commits_schema.sha,
                                                              author_email_field=self.commits_schema.author_email,
                                                              company_field=self.commits_schema.company,
                                                              commits_thresholds=thresholds,
                                                              order_by_field=report_schema.active
                                                              ) \
            .withColumnRenamed(self.commits_schema.company, report_schema.company)