20
20
21
21
from camel .configs import ChatGPTConfig
22
22
from camel .societies import RolePlaying
23
- from camel .typing import TaskType
23
+ from camel .typing import TaskType , ModelType
24
24
from camel .utils import download_tasks
25
25
26
26
27
27
def generate_data (assistant_idx : int , assistant_role_name : str , user_idx : int ,
28
28
user_role_name : str , task_idx : int , task_prompt : str ,
29
29
verbose : bool = False ) -> None :
30
30
31
- max_num_messages = 40
31
+ max_num_messages = 100
32
32
33
33
original_task_prompt = task_prompt .replace (f"{ task_idx + 1 } . " , "" )
34
34
@@ -38,6 +38,7 @@ def generate_data(assistant_idx: int, assistant_role_name: str, user_idx: int,
38
38
task_prompt = original_task_prompt ,
39
39
with_task_specify = True ,
40
40
with_task_planner = False ,
41
+ model_type = ModelType .GPT_3_5_TURBO_16K ,
41
42
task_specify_agent_kwargs = dict (model_config = ChatGPTConfig (
42
43
temperature = 1.4 )),
43
44
)
@@ -204,7 +205,7 @@ def main() -> None:
204
205
try :
205
206
slurm_array_task_id = os .environ .get ('SLURM_ARRAY_TASK_ID' )
206
207
if slurm_array_task_id is None :
207
- raise
208
+ raise ValueError ( "SLURM_ARRAY_TASK_ID is not set" )
208
209
array_idx = int (slurm_array_task_id )
209
210
except (TypeError , ValueError ) as e :
210
211
print (f"Error: { e } " )
@@ -227,7 +228,7 @@ def main() -> None:
227
228
roles_per_chunk :(array_idx + 1 ) *
228
229
roles_per_chunk ]
229
230
230
- pool = multiprocessing .Pool ()
231
+ pool = multiprocessing .Pool (processes = 10 )
231
232
232
233
for assistant_idx , assistant_role_name in enumerate (assistant_roles ):
233
234
assistant_idx += array_idx * roles_per_chunk
0 commit comments