diff --git a/common.py b/common.py index 4b70aae..50647d6 100644 --- a/common.py +++ b/common.py @@ -392,6 +392,7 @@ class TcHandler(TcHandlerBase): seq_cnt_provider=seq_count_provider, pus_verificator=pus_verificator, ) + self.cfdp_done = False self.cfdp_in_ccsds_wrapper = cfdp_in_ccsds_wrapper def feed_cb(self, info: ProcedureWrapper, wrapper: FeedWrapper): @@ -506,6 +507,7 @@ class TcHandler(TcHandlerBase): ) elif info.proc_type == TcProcedureType.CFDP: LOGGER.info(f"Finished CFDP queue") + self.cfdp_done = True def setup_params(hook_obj: TmTcCfgHookBase) -> SetupWrapper: