mirror of
https://github.com/infiniflow/ragflow.git
synced 2026-05-06 10:17:49 +08:00
Feat: inject sys.date into canvas (#13567)
### What problem does this PR solve? Inject sys.date into canvas. ### Type of change - [x] New Feature (non-breaking change which adds functionality)
This commit is contained in:
@ -15,6 +15,7 @@
|
||||
#
|
||||
import asyncio
|
||||
import base64
|
||||
import datetime
|
||||
import inspect
|
||||
import binascii
|
||||
import json
|
||||
@ -287,7 +288,8 @@ class Canvas(Graph):
|
||||
"sys.user_id": tenant_id,
|
||||
"sys.conversation_turns": 0,
|
||||
"sys.files": [],
|
||||
"sys.history": []
|
||||
"sys.history": [],
|
||||
"sys.date": datetime.datetime.now(datetime.timezone.utc).strftime("%Y-%m-%d %H:%M:%S")
|
||||
}
|
||||
self.variables = {}
|
||||
super().__init__(dsl, tenant_id, task_id, custom_header=custom_header)
|
||||
@ -300,13 +302,16 @@ class Canvas(Graph):
|
||||
self.globals = self.dsl["globals"]
|
||||
if "sys.history" not in self.globals:
|
||||
self.globals["sys.history"] = []
|
||||
if "sys.date" not in self.globals:
|
||||
self.globals["sys.date"] = datetime.datetime.now(datetime.timezone.utc).strftime("%Y-%m-%d %H:%M:%S")
|
||||
else:
|
||||
self.globals = {
|
||||
"sys.query": "",
|
||||
"sys.user_id": "",
|
||||
"sys.conversation_turns": 0,
|
||||
"sys.files": [],
|
||||
"sys.history": []
|
||||
"sys.history": [],
|
||||
"sys.date": datetime.datetime.now(datetime.timezone.utc).strftime("%Y-%m-%d %H:%M:%S")
|
||||
}
|
||||
if "variables" in self.dsl:
|
||||
self.variables = self.dsl["variables"]
|
||||
@ -368,6 +373,7 @@ class Canvas(Graph):
|
||||
self.globals[k] = ""
|
||||
|
||||
async def run(self, **kwargs):
|
||||
self.globals["sys.date"] = datetime.datetime.now(datetime.timezone.utc).strftime("%Y-%m-%d %H:%M:%S")
|
||||
st = time.perf_counter()
|
||||
self._loop = asyncio.get_running_loop()
|
||||
self.message_id = get_uuid()
|
||||
|
||||
Reference in New Issue
Block a user