You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@datalab.apache.org by lf...@apache.org on 2021/11/17 15:46:00 UTC

[incubator-datalab] 01/01: [DATALAB-2054]: added right mount path insurance for azure spark

This is an automated email from the ASF dual-hosted git repository.

lfrolov pushed a commit to branch DATALAB-2054
in repository https://gitbox.apache.org/repos/asf/incubator-datalab.git

commit c574fce9da1a840be190cf9cf1b0b97e0e32d1d7
Author: leonidfrolov <fr...@gmail.com>
AuthorDate: Wed Nov 17 17:45:45 2021 +0200

    [DATALAB-2054]: added right mount path insurance for azure spark
---
 .../src/general/scripts/azure/dataengine_configure.py                 | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/infrastructure-provisioning/src/general/scripts/azure/dataengine_configure.py b/infrastructure-provisioning/src/general/scripts/azure/dataengine_configure.py
index 3d25aea..d63f393 100644
--- a/infrastructure-provisioning/src/general/scripts/azure/dataengine_configure.py
+++ b/infrastructure-provisioning/src/general/scripts/azure/dataengine_configure.py
@@ -77,6 +77,8 @@ def configure_slave(slave_number, data_engine):
             .format(slave_hostname, keyfile_name, data_engine['datalab_ssh_user'], os.environ['application'])
         try:
             subprocess.run("~/scripts/{}.py {}".format('common_clean_instance', params), shell=True, check=True)
+            datalab.actions_lib.ensure_right_mount_paths(True, data_engine['datalab_ssh_user'], slave_hostname,
+                                                         keyfile_name)
         except:
             traceback.print_exc()
             raise Exception
@@ -255,6 +257,8 @@ if __name__ == "__main__":
         params = '--hostname {} --keyfile {} --os_user {} --application {}' \
             .format(master_node_hostname, keyfile_name, data_engine['datalab_ssh_user'], os.environ['application'])
         try:
+            datalab.actions_lib.ensure_right_mount_paths(True, data_engine['datalab_ssh_user'], master_node_hostname,
+                                                         keyfile_name)
             subprocess.run("~/scripts/{}.py {}".format('common_clean_instance', params), shell=True, check=True)
         except:
             traceback.print_exc()

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@datalab.apache.org
For additional commands, e-mail: commits-help@datalab.apache.org