From 722cabf5df56ad62d6ffa3f73abc81fd52de1dbe Mon Sep 17 00:00:00 2001 From: Nathan Matthews <29493311+natmatn@users.noreply.github.com> Date: Mon, 20 Nov 2023 12:22:12 -0800 Subject: [PATCH] fix: Adding os_user to FileSystemPermissionSettings for use in the deadline vfs (#94) * fix: Adding os_user to FileSystemPermissionSettings for use in the deadline VFS Signed-off-by: Nathan Matthews * fix: pass in missing os_env_vars variable Signed-off-by: amzn-mike <80125227+amzn-mike@users.noreply.github.com> --------- Signed-off-by: Nathan Matthews Signed-off-by: amzn-mike <80125227+amzn-mike@users.noreply.github.com> Co-authored-by: amzn-mike <80125227+amzn-mike@users.noreply.github.com> Signed-off-by: Graeme McHale --- src/deadline_worker_agent/sessions/session.py | 3 ++- test/unit/sessions/test_session.py | 1 + 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/src/deadline_worker_agent/sessions/session.py b/src/deadline_worker_agent/sessions/session.py index d539436b..983396e2 100644 --- a/src/deadline_worker_agent/sessions/session.py +++ b/src/deadline_worker_agent/sessions/session.py @@ -854,10 +854,11 @@ def progress_handler(job_upload_status: ProgressReportMetadata) -> bool: queue_id=self._queue_id, # only used for error message job_id=self._queue._job_id, # only used for error message session_dir=self._session.working_directory, - fs_permission_settings=fs_permission_settings, + fs_permission_settings=fs_permission_settings, # type: ignore[arg-type] storage_profiles_path_mapping_rules=storage_profiles_path_mapping_rules_dict, step_dependencies=step_dependencies, on_downloading_files=progress_handler, + os_env_vars=self._env, ) ASSET_SYNC_LOGGER.info( diff --git a/test/unit/sessions/test_session.py b/test/unit/sessions/test_session.py index 2bd4c33a..35ba88da 100644 --- a/test/unit/sessions/test_session.py +++ b/test/unit/sessions/test_session.py @@ -568,6 +568,7 @@ def test_asset_loading_method( storage_profiles_path_mapping_rules={}, step_dependencies=None, on_downloading_files=ANY, + os_env_vars=ANY, ) def test_sync_asset_inputs_with_fs_permission_settings(