66import os
77import uuid
88import shutil
9+ from datetime import datetime
910from pathlib import Path
1011from typing import List , Optional , Dict , Any , TYPE_CHECKING
1112
@@ -306,7 +307,6 @@ async def create_operator(
306307 db : AsyncSession
307308 ) -> OperatorDto :
308309 """创建算子"""
309- from datetime import datetime , timezone
310310
311311 # Generate ID if not provided
312312 if not req .id :
@@ -330,7 +330,7 @@ async def create_operator(
330330 release = req .releases [0 ]
331331 release .id = req .id
332332 release .version = req .version
333- release .release_date = datetime .utcnow ()
333+ release .release_date = datetime .now ()
334334 await self .operator_release_repo .insert (release , db )
335335
336336 # Extract files
@@ -350,7 +350,6 @@ async def update_operator(
350350 db : AsyncSession
351351 ) -> OperatorDto :
352352 """更新算子"""
353- from datetime import datetime , timezone
354353
355354 # Get existing operator
356355 existing = await self .get_operator_by_id (operator_id , db )
@@ -406,7 +405,7 @@ async def update_operator(
406405 release = req .releases [0 ]
407406 release .id = operator_id
408407 release .version = req .version
409- release .release_date = datetime .utcnow ()
408+ release .release_date = datetime .now ()
410409 if original_version == release .version :
411410 await self .operator_release_repo .update (release , db )
412411 else :
0 commit comments