Skip to content

Commit

Permalink
Allow the Symlinking for log/job
Browse files Browse the repository at this point in the history
  • Loading branch information
wxtim committed Jun 25, 2024
1 parent 3534126 commit b4b99c5
Show file tree
Hide file tree
Showing 5 changed files with 38 additions and 52 deletions.
1 change: 1 addition & 0 deletions changes.d/feat.6168.md
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
Allow symlinking log/job separately from log
65 changes: 16 additions & 49 deletions cylc/flow/cfgspec/globalcfg.py
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,7 @@
from cylc.flow.exceptions import GlobalConfigError
from cylc.flow.hostuserutil import get_user_home
from cylc.flow.network.client_factory import CommsMeth
from cylc.flow.pathutil import SYMLINKABLE_LOCATIONS
from cylc.flow.parsec.config import (
ConfigNode as Conf,
ParsecConfig,
Expand Down Expand Up @@ -1148,55 +1149,21 @@ def default_for(
.. versionadded:: 8.0.0
""")
Conf('log', VDR.V_STRING, None, desc="""
Alternative location for the log dir.
If specified the workflow log directory will be created in
``<this-path>/cylc-run/<workflow-id>/log`` and a
symbolic link will be created from
``$HOME/cylc-run/<workflow-id>/log``. If not specified
the workflow log directory will be created in
``$HOME/cylc-run/<workflow-id>/log``.
.. versionadded:: 8.0.0
""")
Conf('share', VDR.V_STRING, None, desc="""
Alternative location for the share dir.
If specified the workflow share directory will be
created in ``<this-path>/cylc-run/<workflow-id>/share``
and a symbolic link will be created from
``<$HOME/cylc-run/<workflow-id>/share``. If not specified
the workflow share directory will be created in
``$HOME/cylc-run/<workflow-id>/share``.
.. versionadded:: 8.0.0
""")
Conf('share/cycle', VDR.V_STRING, None, desc="""
Alternative directory for the share/cycle dir.
If specified the workflow share/cycle directory
will be created in
``<this-path>/cylc-run/<workflow-id>/share/cycle``
and a symbolic link will be created from
``$HOME/cylc-run/<workflow-id>/share/cycle``. If not
specified the workflow share/cycle directory will be
created in ``$HOME/cylc-run/<workflow-id>/share/cycle``.
.. versionadded:: 8.0.0
""")
Conf('work', VDR.V_STRING, None, desc="""
Alternative directory for the work dir.
If specified the workflow work directory will be created in
``<this-path>/cylc-run/<workflow-id>/work`` and a
symbolic link will be created from
``$HOME/cylc-run/<workflow-id>/work``. If not specified
the workflow work directory will be created in
``$HOME/cylc-run/<workflow-id>/work``.
.. versionadded:: 8.0.0
""")
for folder, versionadded in SYMLINKABLE_LOCATIONS.items():
Conf(folder, VDR.V_STRING, None, desc=f"""
Alternative location for the log dir.
If specified the workflow {folder} directory will
be created in
``<this-path>/cylc-run/<workflow-id>/{folder}``
and a symbolic link will be created from
``$HOME/cylc-run/<workflow-id>/{folder}``.
If not specified the workflow log directory will
be created in
``$HOME/cylc-run/<workflow-id>/{folder}``.
.. versionadded:: {versionadded}
""")
with Conf('platforms', desc='''
Platforms allow you to define compute resources available at your
site.
Expand Down
11 changes: 9 additions & 2 deletions cylc/flow/pathutil.py
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,14 @@
"""Matches relative paths that are explicit (starts with ./)"""

SHELL_ENV_VARS = re.compile(r'\$[^$/]*')

SYMLINKABLE_LOCATIONS: Dict[str, str] = {
# Location: Version Added
'log': '8.0.0',
'log/job': '8.4.0',
'share': '8.0.0',
'share/cycle': '8.0.0',
'work': '8.0.0'
}

def expand_path(*args: Union[Path, str]) -> str:
"""Expand both vars and user in path and normalise it, joining any
Expand Down Expand Up @@ -234,7 +241,7 @@ def get_dirs_to_symlink(
if base_dir:
dirs_to_symlink['run'] = os.path.join(
base_dir, 'cylc-run', workflow_id)
for dir_ in ['log', 'share', 'share/cycle', 'work']:
for dir_ in SYMLINKABLE_LOCATIONS.keys():
link = symlink_conf[install_target].get(dir_, None)
if (not link) or link == base_dir:
continue
Expand Down
11 changes: 10 additions & 1 deletion tests/functional/cylc-install/01-symlinks.t
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ if [[ -z ${TMPDIR:-} || -z ${USER:-} || $TMPDIR/$USER == "$HOME" ]]; then
skip_all '"TMPDIR" or "USER" not defined or "TMPDIR"/"USER" is "HOME"'
fi

set_test_number 30
set_test_number 32

create_test_global_config "" "
[install]
Expand All @@ -33,6 +33,7 @@ create_test_global_config "" "
run = \$TMPDIR/\$USER/test_cylc_symlink/cylctb_tmp_run_dir
share = \$TMPDIR/\$USER/test_cylc_symlink/
log = \$TMPDIR/\$USER/test_cylc_symlink/
log/job = \$TMPDIR/\$USER/test_cylc_symlink/job_log_dir
share/cycle = \$TMPDIR/\$USER/test_cylc_symlink/cylctb_tmp_share_dir
work = \$TMPDIR/\$USER/test_cylc_symlink/
"
Expand All @@ -53,6 +54,10 @@ TEST_SYM="${TEST_NAME_BASE}-share-cycle-glblcfg"
run_ok "${TEST_SYM}" test "$(readlink "${WORKFLOW_RUN_DIR}/share/cycle")" \
= "$TMPDIR/${USER}/test_cylc_symlink/cylctb_tmp_share_dir/cylc-run/${RND_WORKFLOW_NAME}/run1/share/cycle"

TEST_SYM="${TEST_NAME_BASE}-log-job-glblcfg"
run_ok "${TEST_SYM}" test "$(readlink "${WORKFLOW_RUN_DIR}/log/job")" \
= "$TMPDIR/${USER}/test_cylc_symlink/job_log_dir/cylc-run/${RND_WORKFLOW_NAME}/run1/log/job"

for DIR in 'work' 'share' 'log'; do
TEST_SYM="${TEST_NAME_BASE}-${DIR}-glbcfg"
run_ok "${TEST_SYM}" test "$(readlink "${WORKFLOW_RUN_DIR}/${DIR}")" \
Expand Down Expand Up @@ -137,6 +142,10 @@ TEST_SYM="${TEST_NAME}-share-cycle"
run_fail "${TEST_SYM}" test "$(readlink "${WORKFLOW_RUN_DIR}/share/cycle")" \
= "$TMPDIR/${USER}/test_cylc_symlink/cylctb_tmp_share_dir/cylc-run/${RND_WORKFLOW_NAME}/run1/share/cycle"

TEST_SYM="${TEST_NAME}-log-job"
run_fail "${TEST_SYM}" test "$(readlink "${WORKFLOW_RUN_DIR}/log/job")" \
= "$TMPDIR/${USER}/test_cylc_symlink/job_log_dir/cylc-run/${RND_WORKFLOW_NAME}/run1/log/job"

for DIR in 'work' 'share' 'log'; do
TEST_SYM="${TEST_NAME}-${DIR}"
run_fail "${TEST_SYM}" test "$(readlink "${WORKFLOW_RUN_DIR}/${DIR}")" \
Expand Down
2 changes: 2 additions & 0 deletions tests/unit/test_pathutil.py
Original file line number Diff line number Diff line change
Expand Up @@ -203,13 +203,15 @@ def test_make_workflow_run_tree(
run = $DEE
work = $DAH
log = $DUH
log/job =$RAY
share = $DOH
share/cycle = $DAH
''',
{
'run': '$DEE/cylc-run/morpheus',
'work': '$DAH/cylc-run/morpheus/work',
'log': '$DUH/cylc-run/morpheus/log',
'log/job': '$RAY/cylc-run/morpheus/log/job',
'share': '$DOH/cylc-run/morpheus/share',
'share/cycle': '$DAH/cylc-run/morpheus/share/cycle'
},
Expand Down

0 comments on commit b4b99c5

Please sign in to comment.