Commit 828335a

authored

Merge pull request #167 from mz-ko/master

test: rollback loggers

2 parents 8d467bf + 773b5c5 commit 828335aCopy full SHA for 828335a

File tree

-22

lines changed

-22

lines changed

Lines changed: 0 additions & 9 deletions

Original file line number	Diff line number	Diff line change
`@@ -44,7 +44,6 @@ def client(self) -> GRPCClient:`
`44`	`44`	`return self._client`
`45`	`45`
`46`	`46`	`def dispatch(self, method: str, params: dict = None, **kwargs) -> Any:`
`47`		`- _LOGGER.debug(f"space_connector.dispatch : method: {method}")`
`48`	`47`	`return self._call_api(method, params, **kwargs)`
`49`	`48`
`50`	`49`	`def _call_api(`
`@@ -56,23 +55,15 @@ def _call_api(`
`56`	`55`	`x_workspace_id: str = None,`
`57`	`56`	`) -> Any:`
`58`	`57`	`resource, verb = self._parse_method(method)`
`59`		`- _LOGGER.debug(f"space_connector.dispatch :: resource: {resource}, verb: {verb}")`
`60`		`-`
`61`	`58`	`self._check_method(resource, verb)`
`62`	`59`
`63`	`60`	`params = params or {}`
`64`		`- _LOGGER.debug(f"space_connector.dispatch :: params: {params}")`
`65`	`61`	`metadata = self._get_connection_metadata(token, x_domain_id, x_workspace_id)`
`66`		`- _LOGGER.debug(f"space_connector.dispatch :: metadata: {metadata}")`
`67`	`62`
`68`	`63`	`response_or_iterator = getattr(getattr(self._client, resource), verb)(`
`69`	`64`	`params, metadata=metadata`
`70`	`65`	`)`
`71`	`66`
`72`		`- _LOGGER.debug(`
`73`		`- f"space_connector.dispatch :: response_or_iterator: {response_or_iterator}"`
`74`		`- )`
`75`		`-`
`76`	`67`	`if self._return_type == "dict":`
`77`	`68`	`if isinstance(response_or_iterator, types.GeneratorType):`
`78`	`69`	`return self._generate_response(response_or_iterator)`

Lines changed: 0 additions & 13 deletions

Original file line number	Diff line number	Diff line change
`@@ -109,24 +109,16 @@ def _retry_call(`
`109`	`109`	`):`
`110`	`110`	`retries = 0`
`111`	`111`
`112`		`- _LOGGER.debug(`
`113`		`- f"client._retry_call.init :: client_call_details: {client_call_details}"`
`114`		`- )`
`115`		`-`
`116`	`112`	`while True:`
`117`	`113`	`try:`
`118`		`- _LOGGER.debug(f"client._retry_call.start!!!")`
`119`	`114`	`response_or_iterator = continuation(`
`120`	`115`	`client_call_details, request_or_iterator`
`121`	`116`	`)`
`122`		`- _LOGGER.debug(f"client._retry_call.response_or_iterator Success!!!")`
`123`	`117`
`124`	`118`	`if is_stream:`
`125`	`119`	`response_or_iterator = self._generate_response(response_or_iterator)`
`126`	`120`	`else:`
`127`		`- _LOGGER.debug(f"client._retry_call.start _check_error!!!")`
`128`	`121`	`self._check_error(response_or_iterator)`
`129`		`- _LOGGER.debug(f"client._retry_call.finished _check_error!!!")`
`130`	`122`
`131`	`123`	`return response_or_iterator`
`132`	`124`
`@@ -338,11 +330,6 @@ def client(endpoint=None, ssl_enabled=False, max_message_length=None, **client_o`
`338`	`330`	`if endpoint is None:`
`339`	`331`	`raise Exception("Client's endpoint is undefined.")`
`340`	`332`
`341`		`- _LOGGER.debug(f"pygrpc.client :: endpoint: {endpoint}")`
`342`		`- _LOGGER.debug(`
`343`		`- f"pygrpc.client :: _GRPC_CHANNEL: {_GRPC_CHANNEL} / is in? {endpoint in _GRPC_CHANNEL}"`
`344`		`- )`
`345`		`-`
`346`	`333`	`if endpoint not in _GRPC_CHANNEL:`
`347`	`334`	`options = []`
`348`	`335`

Comments

(0)