Spaces:
Sleeping
Sleeping
Xu Xuenan
commited on
Commit
·
6fc0fd0
1
Parent(s):
15c0d2f
Multi-process to single-process
Browse files- mm_story_agent/__init__.py +14 -8
mm_story_agent/__init__.py
CHANGED
@@ -45,16 +45,22 @@ class MMStoryAgent:
|
|
45 |
for modality in self.modalities:
|
46 |
agents[modality] = self.modality_agent_class[modality](config[modality + "_generation"])
|
47 |
|
48 |
-
processes = []
|
49 |
-
return_dict = mp.Manager().dict()
|
50 |
|
51 |
-
for modality in self.modalities:
|
52 |
-
|
53 |
-
|
54 |
-
|
55 |
|
56 |
-
for p in processes:
|
57 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
58 |
|
59 |
for modality, result in return_dict.items():
|
60 |
try:
|
|
|
45 |
for modality in self.modalities:
|
46 |
agents[modality] = self.modality_agent_class[modality](config[modality + "_generation"])
|
47 |
|
48 |
+
# processes = []
|
49 |
+
# return_dict = mp.Manager().dict()
|
50 |
|
51 |
+
# for modality in self.modalities:
|
52 |
+
# p = mp.Process(target=self.call_modality_agent, args=(agents[modality], pages, story_dir / modality, return_dict), daemon=False)
|
53 |
+
# processes.append(p)
|
54 |
+
# p.start()
|
55 |
|
56 |
+
# for p in processes:
|
57 |
+
# p.join()
|
58 |
+
|
59 |
+
|
60 |
+
return_dict = {}
|
61 |
+
|
62 |
+
for modality in self.modalities:
|
63 |
+
self.call_modality_agent(agents[modality], pages, story_dir / modality, return_dict)
|
64 |
|
65 |
for modality, result in return_dict.items():
|
66 |
try:
|