def expand()

in flex-templates/python/regional_dlp_transform/bigquery_dlp_bigquery.py [0:0]

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

    def expand(self, pcoll):
        if self.project is None:
            self.project = pcoll.pipeline.options.view_as(
                GoogleCloudOptions).project
        if self.project is None:
            raise ValueError(
                'GCP project name needs to be specified '
                'in "dlp_project" pipeline option.'
                )
        return (
            pcoll
            | ParDo(_ReidentifyFn(
                self.config,
                self.timeout,
                self.project,
                self.location
            )))