@GoogleCloudBaseHook.catch_http_exception<EOL><INDENT>@GoogleCloudBaseHook.fallback_to_default_project_id<EOL>def add_product_to_product_set(<EOL>self,<EOL>product_set_id,<EOL>product_id,<EOL>location=None,<EOL>project_id=None,<EOL>retry=None,<EOL>timeout=None,<EOL>metadata=None,<EOL>):<DEDENT>
client = self.get_conn()<EOL>product_name = ProductSearchClient.product_path(project_id, location, product_id)<EOL>product_set_name = ProductSearchClient.product_set_path(project_id, location, product_set_id)<EOL>self.log.info('<STR_LIT>', product_name, product_set_name)<EOL>client.add_product_to_product_set(<EOL>name=product_set_name, product=product_name, retry=retry, timeout=timeout, metadata=metadata<EOL>)<EOL>self.log.info('<STR_LIT>')<EOL>
For the documentation see:
:py:class:`~airflow.contrib.operators.gcp_vision_operator.CloudVisionAddProductToProductSetOperator`