Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions Dockerfile
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,9 @@ RUN cd /tmp && \
RUN pip install --no-cache-dir --upgrade pip && \
pip install --no-cache-dir \
astropy==6.1.0 \
astroquery \
cs_util==0.1.9 \
fitsio \
galsim==2.5.3 \
ipython==8.18.1 \
joblib==1.4.2 \
Expand All @@ -71,6 +73,7 @@ RUN pip install --no-cache-dir --upgrade pip && \
mccd==1.2.4 \
modopt==1.6.1 \
mpi4py==4.0.3 \
numba \
numpy==1.26.4 \
numpydoc==1.2 \
pandas==2.2 \
Expand All @@ -79,6 +82,7 @@ RUN pip install --no-cache-dir --upgrade pip && \
pytest-pycodestyle==2.4.1 \
pytest-pydocstyle==2.4.0 \
reproject==0.14.1 \
"setuptools<81" \
sf_tools==2.0.4 \
sip_tpv==1.1 \
skaha==1.7.0 \
Expand Down
2 changes: 1 addition & 1 deletion src/shapepipe/canfar/canfar_monitor.py
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ def set_params_from_command_line(self, args):
logging.log_command(args)

def params_default(self):
"""Params Default.
"""Params Default.

Set default parameters.

Expand Down
48 changes: 33 additions & 15 deletions src/shapepipe/summary_run.py
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
#!/usr/bin/env python

import argparse
import sys
import os

Expand All @@ -8,16 +9,7 @@
from shapepipe.utilities import summary_params_pre_v2 as summary_params


def run(*args):

patch = args[0]

if len(args) >= 2:
job_exclusive = args[1]
else:
job_exclusive = None

verbose = len(args) == 3
def run(patch, job_exclusive=None, verbose=False):

jobs, list_tile_IDs_dot = summary_params.set_jobs_v2_pre_v2(patch, verbose)

Expand Down Expand Up @@ -73,11 +65,37 @@ def run(*args):
return 0


def main(args=None):

if args is None:
args = sys.argv[1:] # skip script name
run(*args)
def parse_args(argv=None):
parser = argparse.ArgumentParser(
description=(
'Print summary of ShapePipe job status for a given UNIONS patch.'
),
)
parser.add_argument(
'patch',
help='Patch identifier (e.g. P3, P9).',
)
parser.add_argument(
'job_exclusive',
nargs='?',
default=None,
help=(
'Bitmask selecting which jobs to run; '
+ 'if omitted, all jobs run.'
),
)
parser.add_argument(
'-v',
'--verbose',
action='store_true',
help='Verbose output.',
)
return parser.parse_args(argv)


def main(argv=None):
args = parse_args(argv)
run(args.patch, args.job_exclusive, args.verbose)


if __name__ == "__main__":
Expand Down
Loading