[GitHub] [beam] tvalentyn commented on a diff in pull request #25617: Fail when main session cannot be loaded.

["tvalentyn (via GitHub)" <gi...@apache.org>]

tvalentyn commented on code in PR #25617:
URL: https://github.com/apache/beam/pull/25617#discussion_r1124913595


##########
sdks/python/apache_beam/runners/worker/sdk_worker_main.py:
##########
@@ -120,9 +121,17 @@ def create_harness(environment, dry_run=False):
           'Could not load main session: %s', exception_details, exc_info=True)
       raise
     except Exception:  # pylint: disable=broad-except
+      summary = (
+          "Could not load main session. Inspect which external dependencies "
+          "are used in the main module of your pipeline. Verify that "
+          "corresponding packages are installed in the pipeline runtime "
+          "environment and their installed version match the versions used in "
+          "pipeline submission environment. For more information, see: https://"
+          "beam.apache.org/documentation/sdks/python-pipeline-dependencies/")
+      _LOGGER.error(summary, exc_info=True)
       exception_details = traceback.format_exc()
-      _LOGGER.error(
-          'Could not load main session: %s', exception_details, exc_info=True)
+      deferred_exception = CorruptMainSessionException(

Review Comment:
   made this change.



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org