fix(archive): Correctly pass in the period

devsjc · devsjc · commit 49a215ed650e · 2025-01-06T09:51:01.000Z
diff --git a/src/nwp_consumer/internal/handlers/cli.py b/src/nwp_consumer/internal/handlers/cli.py
@@ -102,10 +102,11 @@ def run(self) -> int:
                     model_adaptor=self.model_adaptor,
                     notification_adaptor=self.notification_adaptor,
                 )
+                period: dt.date = dt.date(args.year, args.month, 1)
                 result = service_result.do(
                     consume_result
                     for service in service_result
-                    for consume_result in service.consume(period=args.init_time)
+                    for consume_result in service.consume(period=period)
                 )
                 if isinstance(result, Failure):
                     log.error(f"Failed to archive NWP data: {result!s}")

Original file line number	Diff line number	Diff line change
`@@ -102,10 +102,11 @@ def run(self) -> int:`
`102`	`102`	`model_adaptor=self.model_adaptor,`
`103`	`103`	`notification_adaptor=self.notification_adaptor,`
`104`	`104`	`)`
	`105`	`+ period: dt.date = dt.date(args.year, args.month, 1)`
`105`	`106`	`result = service_result.do(`
`106`	`107`	`consume_result`
`107`	`108`	`for service in service_result`
`108`		`- for consume_result in service.consume(period=args.init_time)`
	`109`	`+ for consume_result in service.consume(period=period)`
`109`	`110`	`)`
`110`	`111`	`if isinstance(result, Failure):`
`111`	`112`	`log.error(f"Failed to archive NWP data: {result!s}")`