fix: replace 44 bare except clauses with except Exception

Author: haosenwang1018

jina/clients/base/grpc.py

@@ -176,7 +176,7 @@ async def _get_results(
         except asyncio.CancelledError as ex:
             self.logger.warning(f'process error: {ex!r}')
             raise
-        except:
+        except Exception:
             # Not sure why, adding this line helps in fixing a hanging test
             raise
 

jina/clients/base/http.py

@@ -70,7 +70,7 @@ def extract_paths_by_method(spec):
                     self._endpoints = extract_paths_by_method(openapi_response).get(
                         'post', []
                     )
-        except:
+        except Exception:
             pass
 
     async def _is_flow_ready(self, **kwargs) -> bool:

jina/clients/base/websocket.py

@@ -220,7 +220,7 @@ def _request_handler(
                 exception_raised = ex
                 try:
                     receive_task.cancel()
-                except:
+                except Exception:
                     raise ex
             finally:
                 if iolet.close_code == status.WS_1011_INTERNAL_ERROR:

jina/helper.py

@@ -941,11 +941,11 @@ def get_full_version() -> Optional[Tuple[Dict, Dict]]:
 
     try:
         from hubble import __version__ as __hubble_version__
-    except:
+    except Exception:
         __hubble_version__ = 'not-available'
     try:
         from jcloud import __version__ as __jcloud_version__
-    except:
+    except Exception:
         __jcloud_version__ = 'not-available'
 
     from jina import __docarray_version__, __proto_version__, __version__
@@ -1220,7 +1220,7 @@ def _get_ip(url):
                 _ip = fp.read().decode().strip()
                 return _ip
 
-        except:
+        except Exception:
             pass  # intentionally ignored, public ip is not showed
 
     ip_server_list = [
@@ -1357,7 +1357,7 @@ def download_mermaid_url(mermaid_url, output) -> None:
         req = Request(mermaid_url, headers={'User-Agent': 'Mozilla/5.0'})
         with open(output, 'wb') as fp:
             fp.write(urlopen(req).read())
-    except:
+    except Exception:
         from jina.logging.predefined import default_logger
 
         default_logger.error(
@@ -1658,7 +1658,7 @@ def _telemetry():
             )
             urllib.request.urlopen(req)
 
-        except:
+        except Exception:
             pass
 
     threading.Thread(target=_telemetry, daemon=True).start()

jina/importer.py

@@ -169,7 +169,7 @@ def add_modules(*paths):
                     importlib.import_module(path)
                 except ModuleNotFoundError:
                     not_python_module_paths.append(path)
-                except:
+                except Exception:
                     raise
             else:
                 not_python_module_paths.append(path)

jina/jaml/helper.py

@@ -30,7 +30,7 @@ def get_hashable_key(self, key):
         """
         try:
             hash(key)
-        except:
+        except Exception:
             if isinstance(key, list):
                 for i in range(len(key)):
                     if not isinstance(key[i], collections.abc.Hashable):

jina/orchestrate/deployments/__init__.py

@@ -1082,7 +1082,7 @@ def _wait_until_all_ready(self):
 
             try:
                 _ = asyncio.get_event_loop()
-            except:
+            except Exception:
                 loop = asyncio.new_event_loop()
                 asyncio.set_event_loop(loop)
 
@@ -1092,7 +1092,7 @@ async def _f():
             running_in_event_loop = False
             try:
                 asyncio.get_event_loop().run_until_complete(_f())
-            except:
+            except Exception:
                 running_in_event_loop = True
 
             if not running_in_event_loop:
@@ -1193,7 +1193,7 @@ def wait_start_success(self) -> None:
                 self.gateway_pod.wait_start_success()
             for shard_id in self.shards:
                 self.shards[shard_id].wait_start_success()
-        except:
+        except Exception:
             self.close()
             raise
 
@@ -1217,7 +1217,7 @@ async def async_wait_start_success(self) -> None:
 
             await asyncio.gather(*coros)
             self.logger.debug('Deployment started successfully')
-        except:
+        except Exception:
             self.close()
             raise
 
@@ -1288,7 +1288,7 @@ def _parse_devices(value: str, num_devices: int):
                 if len(parts) == 1:
                     try:
                         int(parts[0])
-                    except:
+                    except Exception:
                         use_uuids = True
                     if use_uuids:
                         return parts
@@ -1297,7 +1297,7 @@ def _parse_devices(value: str, num_devices: int):
                 # try to detect if parts are not numbers
                 try:
                     int(parts[0])
-                except:
+                except Exception:
                     use_uuids = True
 
                 if not use_uuids:
@@ -1328,7 +1328,7 @@ def _roundrobin_cuda_device(device_str: Optional[str], replicas: int):
                 num_devices = str(subprocess.check_output(['nvidia-smi', '-L'])).count(
                     'UUID'
                 )
-            except:
+            except Exception:
                 num_devices = int(os.environ.get('CUDA_TOTAL_DEVICES', 0))
                 if num_devices == 0:
                     return

jina/orchestrate/deployments/config/helper.py

@@ -93,7 +93,7 @@ def get_base_executor_version():
             return __version__
         else:
             return 'master'
-    except:
+    except Exception:
         return 'master'
 
 

jina/orchestrate/flow/base.py

@@ -1985,7 +1985,7 @@ async def _async_wait_all():
             # kick off all deployments wait-ready tasks
             try:
                 _ = asyncio.get_event_loop()
-            except:
+            except Exception:
                 loop = asyncio.new_event_loop()
                 asyncio.set_event_loop(loop)
 
@@ -1995,7 +1995,7 @@ async def _f():
             running_in_event_loop = False
             try:
                 asyncio.get_event_loop().run_until_complete(_f())
-            except:
+            except Exception:
                 running_in_event_loop = True
 
             wait_ready_threads = []
@@ -2223,7 +2223,7 @@ def plot(
 
                 display(Image(url=url))
                 showed = True
-            except:
+            except Exception:
                 # no need to panic users
                 pass
 

jina/orchestrate/pods/container.py

@@ -344,7 +344,7 @@ def _get_control_address(self):
                     ctrl_host = client.networks.get(network).attrs['IPAM']['Config'][0][
                         'Gateway'
                     ]
-                except:
+                except Exception:
                     ctrl_host = __docker_host__
             else:
                 ctrl_host = self.args.host