From beb736ff871d2a21f82be47f1a3ac093b8db1e67 Mon Sep 17 00:00:00 2001 From: ljl <17743125563@163.com> Date: Fri, 13 Dec 2024 15:41:05 +0800 Subject: [PATCH] schedule:fix log addv2. --- .../schedule_job_serv_v2/event/spi_log.rs | 20 +++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/backend/middlewares/schedule/src/serv/schedule_job_serv_v2/event/spi_log.rs b/backend/middlewares/schedule/src/serv/schedule_job_serv_v2/event/spi_log.rs index 06b004938..88cccccf7 100644 --- a/backend/middlewares/schedule/src/serv/schedule_job_serv_v2/event/spi_log.rs +++ b/backend/middlewares/schedule/src/serv/schedule_job_serv_v2/event/spi_log.rs @@ -1,6 +1,6 @@ use std::{sync::Arc, task::ready, time::Duration}; -use bios_sdk_invoke::clients::spi_log_client::{LogItemAddReq, LogItemAddV2Req, LogItemFindReq, SpiLogClient}; +use bios_sdk_invoke::clients::spi_log_client::{LogItemAddV2Req, LogItemFindReq, SpiLogClient}; use tardis::{ basic::dto::TardisContext, chrono::Utc, @@ -34,10 +34,10 @@ impl EventComponent for SpiLog { let ctx = self.ctx.clone(); let code = code.to_string(); let _handle = tokio::spawn(async move { - let result = SpiLogClient::add( - LogItemAddReq { + let result = SpiLogClient::addv2( + LogItemAddV2Req { tag: JOB_TAG.to_string(), - content: "add job".into(), + content: tardis::serde_json::Value::Null, key: Some(code.to_string()), op: Some(OP_ADD.to_string()), ts: Some(Utc::now()), @@ -59,10 +59,10 @@ impl EventComponent for SpiLog { let ctx = self.ctx.clone(); let code = code.to_string(); let _handle = tokio::spawn(async move { - let result = SpiLogClient::add( - LogItemAddReq { + let result = SpiLogClient::addv2( + LogItemAddV2Req { tag: JOB_TAG.to_string(), - content: "delete job".into(), + content: tardis::serde_json::Value::Null, key: Some(code.to_string()), op: Some(OP_DELETE.to_string()), ts: Some(Utc::now()), @@ -84,10 +84,10 @@ impl EventComponent for SpiLog { let ctx = self.ctx.clone(); let code = code.to_string(); let _handle = tokio::spawn(async move { - let result = SpiLogClient::add( - LogItemAddReq { + let result = SpiLogClient::addv2( + LogItemAddV2Req { tag: TASK_TAG.to_string(), - content: "start request".into(), + content: tardis::serde_json::Value::Null, key: Some(code.to_string()), op: Some(OP_EXECUTE_START.to_string()), ts: Some(Utc::now()),