def get_bq_write_stream()

in components/doc-registry/src/document_registry_service.py [0:0]

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

    def get_bq_write_stream(cls):
        if cls.bq_write_client is None:
            cls.bq_write_client = bigquery_storage_v1.BigQueryWriteClient(
                client_info=cls.gapic_client_info
            )
        return cls.bq_write_client