@@ -250,8 +250,8 @@ def save_evaluation_results(self, document: Document) -> Optional[Dict[str, Any]
250250 evaluation_date = doc_time
251251 year , month , day = (
252252 doc_time .strftime ("%Y" ),
253- doc_time .strftime ("%m" ),
254- doc_time .strftime ("%d" ),
253+ doc_time .strftime ("%Y-% m" ),
254+ doc_time .strftime ("%Y-%m-% d" ),
255255 )
256256 logger .info (
257257 f"Using document initial_event_time: { document .initial_event_time } for partitioning"
@@ -263,8 +263,8 @@ def save_evaluation_results(self, document: Document) -> Optional[Dict[str, Any]
263263 evaluation_date = datetime .datetime .now ()
264264 year , month , day = (
265265 evaluation_date .strftime ("%Y" ),
266- evaluation_date .strftime ("%m" ),
267- evaluation_date .strftime ("%d" ),
266+ evaluation_date .strftime ("%Y-% m" ),
267+ evaluation_date .strftime ("%Y-%m-% d" ),
268268 )
269269 else :
270270 logger .warning (
@@ -273,8 +273,8 @@ def save_evaluation_results(self, document: Document) -> Optional[Dict[str, Any]
273273 evaluation_date = datetime .datetime .now ()
274274 year , month , day = (
275275 evaluation_date .strftime ("%Y" ),
276- evaluation_date .strftime ("%m" ),
277- evaluation_date .strftime ("%d" ),
276+ evaluation_date .strftime ("%Y-% m" ),
277+ evaluation_date .strftime ("%Y-%m-% d" ),
278278 )
279279
280280 # Escape document ID by replacing slashes with underscores
@@ -435,8 +435,8 @@ def save_metering_data(self, document: Document) -> Optional[Dict[str, Any]]:
435435 timestamp = doc_time
436436 year , month , day = (
437437 doc_time .strftime ("%Y" ),
438- doc_time .strftime ("%m" ),
439- doc_time .strftime ("%d" ),
438+ doc_time .strftime ("%Y-% m" ),
439+ doc_time .strftime ("%Y-%m-% d" ),
440440 )
441441 logger .info (
442442 f"Using document initial_event_time: { document .initial_event_time } for partitioning"
@@ -448,8 +448,8 @@ def save_metering_data(self, document: Document) -> Optional[Dict[str, Any]]:
448448 timestamp = datetime .datetime .now ()
449449 year , month , day = (
450450 timestamp .strftime ("%Y" ),
451- timestamp .strftime ("%m" ),
452- timestamp .strftime ("%d" ),
451+ timestamp .strftime ("%Y-% m" ),
452+ timestamp .strftime ("%Y-%m-% d" ),
453453 )
454454 else :
455455 logger .warning (
@@ -458,8 +458,8 @@ def save_metering_data(self, document: Document) -> Optional[Dict[str, Any]]:
458458 timestamp = datetime .datetime .now ()
459459 year , month , day = (
460460 timestamp .strftime ("%Y" ),
461- timestamp .strftime ("%m" ),
462- timestamp .strftime ("%d" ),
461+ timestamp .strftime ("%Y-% m" ),
462+ timestamp .strftime ("%Y-%m-% d" ),
463463 )
464464
465465 # Escape document ID by replacing slashes with underscores
0 commit comments