4747
4848from domain .types import LevelHierarchyEntry , OverallDigestData
4949from domain .validators import is_valid_overall_digest
50- from infrastructure import get_structured_logger , log_info
50+ from infrastructure import get_structured_logger
5151
5252# 構造化ロガー
5353_logger = get_structured_logger (__name__ )
@@ -111,7 +111,7 @@ def get_shadow_digest_for_level(self, level: str) -> Optional[OverallDigestData]
111111 """
112112 指定レベルのShadowダイジェストを取得
113113
114- finalize_from_shadow.pyで使用: これがRegularDigestの内容になります
114+ finalize_from_shadow.pyで使用: ShadowGrandDigestからoverall_digestを取得
115115
116116 Args:
117117 level: レベル名
@@ -128,7 +128,7 @@ def get_shadow_digest_for_level(self, level: str) -> Optional[OverallDigestData]
128128 )
129129
130130 if not is_valid_overall_digest (overall_digest ):
131- log_info (f"No shadow digest for level: { level } " )
131+ _logger . info (f"No shadow digest for level: { level } " )
132132 return None
133133
134134 # is_valid_overall_digest は TypeGuard なので、
@@ -149,11 +149,11 @@ def promote_shadow_to_grand(self, level: str) -> None:
149149 digest = self .get_shadow_digest_for_level (level )
150150
151151 if not digest :
152- log_info (f"No shadow digest to promote for level: { level } " )
152+ _logger . info (f"No shadow digest to promote for level: { level } " )
153153 return
154154
155155 file_count = len (digest .get ("source_files" , []))
156- log_info (f"Shadow digest ready for promotion: { file_count } file(s)" )
156+ _logger . info (f"Shadow digest ready for promotion: { file_count } file(s)" )
157157 # 実際の昇格処理はfinalize_from_shadow.pyで実行される
158158
159159 def clear_shadow_level (self , level : str ) -> None :
@@ -171,7 +171,7 @@ def clear_shadow_level(self, level: str) -> None:
171171 )
172172
173173 self .shadow_io .save (shadow_data )
174- log_info (f"Cleared ShadowGrandDigest for level: { level } " )
174+ _logger . info (f"Cleared ShadowGrandDigest for level: { level } " )
175175
176176 def cascade_update_on_digest_finalize (self , level : str ) -> None :
177177 """
@@ -186,7 +186,7 @@ def cascade_update_on_digest_finalize(self, level: str) -> None:
186186 Args:
187187 level: レベル名
188188 """
189- log_info (f"[Step 3] ShadowGrandDigest cascade for level: { level } " )
189+ _logger . info (f"[Step 3] ShadowGrandDigest cascade for level: { level } " )
190190 _logger .state ("cascade_update" , starting_for_level = level )
191191
192192 # 1. Shadow → Grand 昇格の確認
@@ -201,17 +201,17 @@ def cascade_update_on_digest_finalize(self, level: str) -> None:
201201 _logger .file_op (f"find_new_files({ next_level } )" , found = len (new_files ))
202202
203203 if new_files :
204- log_info (f"Found { len (new_files )} new file(s) for { next_level } :" )
204+ _logger . info (f"Found { len (new_files )} new file(s) for { next_level } :" )
205205 file_names = [f .name for f in new_files [:5 ]]
206206 suffix = "..." if len (new_files ) > 5 else ""
207207 _logger .file_op ("new_files" , names = f"{ file_names } { suffix } " )
208208
209209 # 3. 次のレベルのShadowに増分追加
210210 self .file_appender .add_files_to_shadow (next_level , new_files )
211211 else :
212- log_info (f"No next level for { level } (top level)" )
212+ _logger . info (f"No next level for { level } (top level)" )
213213
214214 # 4. 現在のレベルのShadowをクリア
215215 self .clear_shadow_level (level )
216216
217- log_info (f"[Step 3] Cascade completed for level: { level } " )
217+ _logger . info (f"[Step 3] Cascade completed for level: { level } " )
0 commit comments