添加UI日志
This commit is contained in:
+2
-2
@@ -22,7 +22,7 @@ deployments:
|
||||
- bitable
|
||||
- sync
|
||||
schedules:
|
||||
- cron: "0 17 40 * *"
|
||||
- cron: "0 8 * * *"
|
||||
timezone: "Asia/Shanghai"
|
||||
active: true
|
||||
work_pool:
|
||||
@@ -43,7 +43,7 @@ deployments:
|
||||
- feishu
|
||||
- notify
|
||||
schedules:
|
||||
- cron: "0 18 20 * *"
|
||||
- cron: "0 9 * * *"
|
||||
timezone: "Asia/Shanghai"
|
||||
active: true
|
||||
work_pool:
|
||||
|
||||
@@ -304,12 +304,26 @@ class DailySyncContext:
|
||||
config: DailySyncConfig
|
||||
|
||||
|
||||
def _log_to_prefect(level_name: str, message: str) -> None:
|
||||
try:
|
||||
from prefect.logging import get_run_logger
|
||||
|
||||
prefect_logger = get_run_logger()
|
||||
except Exception:
|
||||
return
|
||||
log_method = getattr(prefect_logger, level_name.lower(), None)
|
||||
if callable(log_method):
|
||||
log_method(message)
|
||||
|
||||
|
||||
def log_step(message: str) -> None:
|
||||
get_logger().info(message)
|
||||
_log_to_prefect("INFO", message)
|
||||
|
||||
|
||||
def log_debug(message: str) -> None:
|
||||
get_logger().debug(message)
|
||||
_log_to_prefect("DEBUG", message)
|
||||
|
||||
|
||||
def preview_list(values: list[Any], limit: int = 20) -> str:
|
||||
|
||||
Reference in New Issue
Block a user