Skip to content

Commit

Permalink
Merge pull request #12 from dirac-institute/awo/app-imports-and-results
Browse files Browse the repository at this point in the history
Move imports into create_uri_manifest, ensure that futures resolve.
  • Loading branch information
drewoldag authored Jul 15, 2024
2 parents 7fccef9 + d2d3052 commit efc9494
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion src/kbmod_wf/workflow.py
Original file line number Diff line number Diff line change
@@ -1,5 +1,4 @@
import argparse
import glob
import os
import parsl
from parsl import python_app, File
Expand All @@ -14,10 +13,14 @@
def create_uri_manifest(inputs=[], outputs=[], directory_path=None, logging_file=None):
"""This app will go to a given directory, find all of the uri.lst files there,
and copy the paths to the manifest file."""
import glob
import os
from kbmod_wf.utilities.logger_utilities import configure_logger

logger = configure_logger("task.create_uri_manifest", logging_file.filepath)

#! We need to do something about this immediately. `__file__` doesn't seem to
#! be valid here when running on klone
if directory_path is None:
this_dir = os.path.dirname(os.path.abspath(__file__))
directory_path = os.path.abspath(os.path.join(this_dir, "../../dev_staging"))
Expand Down Expand Up @@ -182,6 +185,8 @@ def workflow_runner(env=None):
)
)

[f.result() for f in search_futures]

logger.info("Workflow complete")

parsl.clear()
Expand Down

0 comments on commit efc9494

Please sign in to comment.