def _get_date_partitioned_paths()

in osci/datalake/blob/staging.py [0:0]

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

    def _get_date_partitioned_paths(self, dir_path: str, year: Union[str, int] = None,
                                    month: Union[str, int] = None,
                                    day: Union[str, int] = None,
                                    company: str = None) -> Iterable[str]:
        dir_path += '/'
        if year is not None:
            dir_path += f'{year}/'
            if month is not None:
                dir_path += f'{str(month).zfill(2)}/'
                if day is not None:
                    dir_path += f'{str(day).zfill(2)}/'
                    if company is not None:
                        dir_path += f'{normalize_company(name=company)}-'

        return (blob['name'] for blob in self.container_client.list_blobs(name_starts_with=dir_path))