feat(grpc): refine error message on deadline exceeded

python_modules/dagster/dagster/_grpc/client.py

@@ -137,6 +137,18 @@ def _query(
     ):
         try:
             return self._get_response(method, request=request_type(**kwargs), timeout=timeout)
+        except grpc.RpcError as rpc_error:
+            if rpc_error.code() == grpc.StatusCode.DEADLINE_EXCEEDED:
+                raise DagsterUserCodeUnreachableError(
+                    f"Your code location server took longer to respond than the {timeout} second timeout."
+                    " One reason this might happen is if you are running a schedule or sensor"
+                    " that is taking a long time to evaluate its tick. \n\n"
+                    "You can fix this error by optimizing your evaluation function to be faster"
+                    f"than the {timeout} second timeout, or by setting the environment variable"
+                    f" `DAGSTER_GRPC_TIMEOUT_SECONDS` to be a value larger than {timeout}."
+                ) from rpc_error
+
+            raise
         except Exception as e:
             raise DagsterUserCodeUnreachableError("Could not reach user code server") from e
 

python_modules/dagster/dagster/_grpc/server.py

@@ -1006,7 +1006,7 @@ def wait_for_grpc_server(server_process, client, subprocess_args, timeout=60):
         try:
             client.ping("")
             return
-        except DagsterUserCodeUnreachableError:
+        except grpc._channel._InactiveRpcError:
             last_error = serializable_error_info_from_exc_info(sys.exc_info())
 
         if timeout > 0 and (time.time() - start_time > timeout):