The schema_service/client.py did not receive the fixes in this change: [297](https://github.com/googleapis/python-pubsub/pull/297) So you receive the same errors as described in the issue: [290](https://github.com/googleapis/python-pubsub/issues/290) I have created a fork where I added the code and verified this is all that needs to change for this to work with the pubsub emulator: ``` emulator_host = os.environ.get("PUBSUB_EMULATOR_HOST") if emulator_host: if issubclass(Transport, type(self)._transport_registry["grpc"]): channel = grpc.insecure_channel(target=emulator_host) else: channel = grpc.aio.insecure_channel(target=emulator_host) Transport = functools.partial(Transport, channel=channel) ``` The fix is extremely simple as the work has already been done :)
The schema_service/client.py did not receive the fixes in this change: 297
So you receive the same errors as described in the issue: 290
I have created a fork where I added the code and verified this is all that needs to change for this to work with the pubsub emulator:
The fix is extremely simple as the work has already been done :)