diff --git a/config.yaml b/config.yaml index 3b892cc..1f9c6fc 100644 --- a/config.yaml +++ b/config.yaml @@ -84,4 +84,4 @@ levels: seconds: [1] escalation: [10000] schedule: "* * * * *" - options: \ No newline at end of file + options: diff --git a/punchpipe/cli.py b/punchpipe/cli.py index ee163d8..e7da21e 100644 --- a/punchpipe/cli.py +++ b/punchpipe/cli.py @@ -11,10 +11,7 @@ from punchpipe.control.health import update_machine_health_stats from punchpipe.control.launcher import launcher_flow from punchpipe.control.util import load_pipeline_configuration -from punchpipe.flows.fcorona import ( - f_corona_process, - f_corona_scheduler, -) +from punchpipe.flows.fcorona import f_corona_process, f_corona_scheduler from punchpipe.flows.level0 import level0_form_images, level0_ingest_raw_packets from punchpipe.flows.level1 import level1_process_flow, level1_scheduler_flow from punchpipe.flows.level2 import level2_process_flow, level2_scheduler_flow @@ -25,10 +22,7 @@ level3_PTM_scheduler_flow, ) from punchpipe.flows.levelq import levelq_process_flow, levelq_scheduler_flow -from punchpipe.flows.starfield import ( - starfield_process_flow, - starfield_scheduler_flow, -) +from punchpipe.flows.starfield import starfield_process_flow, starfield_scheduler_flow from punchpipe.monitor.app import create_app THIS_DIR = os.path.dirname(__file__) @@ -232,4 +226,4 @@ def run(configuration_path): monitor_process = subprocess.Popen(["gunicorn", "-b", "0.0.0.0:8050", "--chdir", THIS_DIR, - "cli:server"]) \ No newline at end of file + "cli:server"]) diff --git a/punchpipe/flows/fcorona.py b/punchpipe/flows/fcorona.py index 9fec344..1ec7a72 100644 --- a/punchpipe/flows/fcorona.py +++ b/punchpipe/flows/fcorona.py @@ -3,8 +3,8 @@ import random import typing as t from datetime import datetime, timedelta -from dateutil.parser import parse as parse_datetime_str +from dateutil.parser import parse as parse_datetime_str from prefect import flow, get_run_logger, task from punchbowl.level3.f_corona_model import construct_polarized_f_corona_model diff --git a/punchpipe/flows/level0.py b/punchpipe/flows/level0.py index d9b4c08..e635888 100644 --- a/punchpipe/flows/level0.py +++ b/punchpipe/flows/level0.py @@ -12,11 +12,21 @@ from sqlalchemy import and_ from punchpipe import __version__ as software_version -from punchpipe.level0.core import detect_new_tlm_files, update_tlm_database, parse_new_tlm_files, process_telemetry_file, form_from_jpeg_compressed, image_is_okay, get_fits_metadata, form_preliminary_wcs -from punchpipe.level0.meta import POSITIONS_TO_CODES, convert_pfw_position_to_polarizer -from punchpipe.level0.ccsds import unpack_compression_settings +from punchpipe.control.db import File, SciPacket, TLMFiles from punchpipe.control.util import get_database_session, load_pipeline_configuration -from punchpipe.control.db import TLMFiles, SciPacket, File +from punchpipe.level0.ccsds import unpack_compression_settings +from punchpipe.level0.core import ( + detect_new_tlm_files, + form_from_jpeg_compressed, + form_preliminary_wcs, + get_fits_metadata, + image_is_okay, + parse_new_tlm_files, + process_telemetry_file, + update_tlm_database, +) +from punchpipe.level0.meta import POSITIONS_TO_CODES, convert_pfw_position_to_polarizer + @flow def level0_ingest_raw_packets(session=None): diff --git a/punchpipe/flows/level3.py b/punchpipe/flows/level3.py index c16c2d7..bb4e83d 100644 --- a/punchpipe/flows/level3.py +++ b/punchpipe/flows/level3.py @@ -2,8 +2,8 @@ import json import typing as t from datetime import datetime, timedelta -from dateutil.parser import parse as parse_datetime_str +from dateutil.parser import parse as parse_datetime_str from prefect import flow, get_run_logger, task from punchbowl.level3.flow import level3_core_flow, level3_PIM_flow from sqlalchemy import and_ diff --git a/punchpipe/level0/ccsds.py b/punchpipe/level0/ccsds.py index 5038672..0bab2bf 100644 --- a/punchpipe/level0/ccsds.py +++ b/punchpipe/level0/ccsds.py @@ -174,4 +174,4 @@ def unpack_acquisition_settings(acq_set_val: "bytes|int"): # fig.colorbar(im1, ax=axs[1]) fig.tight_layout() fig.savefig("mmr_image.png", dpi=300) - plt.show() \ No newline at end of file + plt.show() diff --git a/punchpipe/level0/core.py b/punchpipe/level0/core.py index 6d69dc0..1e1bb02 100644 --- a/punchpipe/level0/core.py +++ b/punchpipe/level0/core.py @@ -262,4 +262,3 @@ def form_from_jpeg_compressed(packets): """Form a JPEG-LS image from packets""" img = pylibjpeg.decode(packets.tobytes()) return img -