This is an automated email from the ASF dual-hosted git repository.
shunping pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 525780e7af7 Provide a better error when beam plugin was supplied but
wasn't staged. (#39440)
525780e7af7 is described below
commit 525780e7af7396e10b07fb0522a8493e22f32fbb
Author: tvalentyn <[email protected]>
AuthorDate: Thu Jul 30 08:14:17 2026 -0700
Provide a better error when beam plugin was supplied but wasn't staged.
(#39440)
* Provide better error when beam plugin was supplied but wasn't staged.
* formatting
---
sdks/python/apache_beam/runners/worker/sdk_worker_main.py | 13 +++++++++----
1 file changed, 9 insertions(+), 4 deletions(-)
diff --git a/sdks/python/apache_beam/runners/worker/sdk_worker_main.py
b/sdks/python/apache_beam/runners/worker/sdk_worker_main.py
index 1c464141f7e..8bee86f010f 100644
--- a/sdks/python/apache_beam/runners/worker/sdk_worker_main.py
+++ b/sdks/python/apache_beam/runners/worker/sdk_worker_main.py
@@ -58,17 +58,22 @@ def _import_beam_plugins(plugins):
try:
importlib.import_module(plugin)
_LOGGER.debug('Imported beam-plugin %s', plugin)
- except ImportError:
+ except ImportError as exc:
+ if '.' not in plugin:
+ _LOGGER.warning('Failed to import beam-plugin %s', plugin,
exc_info=exc)
+ continue
+
try:
_LOGGER.debug((
"Looks like %s is not a module. "
- "Trying to import it assuming it's a class"),
+ "Trying to import it assuming it's a class."),
plugin)
module, _ = plugin.rsplit('.', 1)
importlib.import_module(module)
_LOGGER.debug('Imported %s for beam-plugin %s', module, plugin)
- except ImportError as exc:
- _LOGGER.warning('Failed to import beam-plugin %s', plugin,
exc_info=exc)
+ except ImportError as fallback_exc:
+ _LOGGER.warning(
+ 'Failed to import beam-plugin %s', plugin, exc_info=fallback_exc)
def create_harness(environment, dry_run=False):
