Skip to content

Commit

Permalink
use any created or progressed for L3 PTM
Browse files Browse the repository at this point in the history
  • Loading branch information
jmbhughes committed Nov 20, 2024
1 parent 574f7bf commit e394b78
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion punchpipe/flows/level3.py
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ def get_valid_fcorona_models(session, f: File, before_timedelta: timedelta, afte
@task
def level3_PTM_query_ready_files(session, pipeline_config: dict):
logger = get_run_logger()
all_ready_files = session.query(File).where(and_(and_(File.state == "created",
all_ready_files = session.query(File).where(and_(and_(File.state.in_(["progressed", "created"]),
File.level == "2"),
File.file_type == "PT")).all()
logger.info(f"{len(all_ready_files)} Level 3 PTM files need to be processed.")
Expand Down

0 comments on commit e394b78

Please sign in to comment.