Repository: beam Updated Branches: refs/heads/master 0806183c4 -> a1e8ac4fa
Fix relative path after file move Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b03366de Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b03366de Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b03366de Branch: refs/heads/master Commit: b03366defc16cca852eb9d42b98ae5bccd7a4ce1 Parents: 0806183 Author: Ahmet Altay <[email protected]> Authored: Thu Feb 23 09:55:16 2017 -0800 Committer: Ahmet Altay <[email protected]> Committed: Thu Feb 23 13:09:08 2017 -0800 ---------------------------------------------------------------------- sdks/python/apache_beam/runners/dataflow/internal/dependency.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/b03366de/sdks/python/apache_beam/runners/dataflow/internal/dependency.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/runners/dataflow/internal/dependency.py b/sdks/python/apache_beam/runners/dataflow/internal/dependency.py index 6024332..97998c9 100644 --- a/sdks/python/apache_beam/runners/dataflow/internal/dependency.py +++ b/sdks/python/apache_beam/runners/dataflow/internal/dependency.py @@ -366,7 +366,8 @@ def stage_job_resources( if setup_options.sdk_location == 'default': module_path = os.path.abspath(__file__) sdk_path = os.path.join( - os.path.dirname(module_path), '..', names.DATAFLOW_SDK_TARBALL_FILE) + os.path.dirname(module_path), '..', '..', '..', + names.DATAFLOW_SDK_TARBALL_FILE) elif os.path.isdir(setup_options.sdk_location): sdk_path = os.path.join( setup_options.sdk_location, names.DATAFLOW_SDK_TARBALL_FILE)
