Skip to content
GitLab
Projects
Groups
Snippets
Help
Loading...
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
Open sidebar
csst
Scalebox Apps
Commits
029566c0
"vscode:/vscode.git/clone" did not exist on "e06f46dc480a37209a31465b44b0cc8a9c68586a"
Commit
029566c0
authored
Nov 26, 2025
by
Zhang Xiaoli
Browse files
解决流水线中多个模块调度异常问题
parent
ba80182e
Changes
2
Show whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
6 additions
and
3 deletions
+6
-3
L1/dockerfiles/message-router/Makefile
L1/dockerfiles/message-router/Makefile
+5
-2
L1/dockerfiles/message-router/messageRoute.py
L1/dockerfiles/message-router/messageRoute.py
+1
-1
No files found.
L1/dockerfiles/message-router/Makefile
View file @
029566c0
IMAGE_NAME
:=
csst/message-router-
hstdm
IMAGE_NAME
:=
csst/message-router-
mbi:
build
:
docker
build
--network
=
host
-t
$(IMAGE_NAME)
.
docker
save
$(IMAGE_NAME)
>
../img/message-router-mbi.img
scp ../img/message-router-mbi.img csst-csu
:
/nfs/scalebox/img/
dist
:
docker save
$(IMAGE_NAME)
| zstdmt | pv | ssh c0
'zstd -d | docker load'
...
...
L1/dockerfiles/message-router/messageRoute.py
View file @
029566c0
...
...
@@ -40,7 +40,7 @@ class messageRoute():
messageRoute
.
appready
(
dagfile
,
sorted_tag
,
dag_run_id
,
data_list
,
message
)
else
:
try
:
headersstr
=
json
.
loads
(
headers
)
#
headersstr = json.loads(headers)
from_job
=
headersstr
[
"from_job"
]
#from_ip=headersstr["from_ip"]
dag_run_id
=
headersstr
[
"dag_run_id"
]
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment