def process()

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


    def process(self, element, **kwargs):
        request = {
            'parent': self.params['parent'],
            'item': element
        }

        if self.config['deidentify_template_name'] is not None:
            request['deidentify_template_name'] = \
                self.config['deidentify_template_name']
        else:
            request['deidentify_config'] = self.config['deidentify_config']

        operation = self.client.deidentify_content(
            timeout=self.timeout,
            request=request
        )
        yield operation.item