def expand()

in flex-templates/python/regional_dlp_de_identification/pubsub_dlp_bigquery.py [0:0]

• 16 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 "project" pipeline option')
        return (
            pcoll
            | ParDo(_DeidentifyFn(
                self.config,
                self.timeout,
                self.project,
                self.location
            )))