@@ -192,53 +192,53 @@ def run(
192
192
solver_version = solver_version ,
193
193
reduce_simulation = reduce_simulation ,
194
194
)
195
- print (batch_task .batch_task_name_map )
196
- print (batch_task .batch_task_name_map .values ())
197
- for port , task_id_i in batch_task .batch_task_name_map .items ():
198
- simulation_i = modeler .sim_dict [port ]
199
- task_id_i_r = upload (
200
- simulation = simulation_i ,
201
- task_id = task_id_i ,
202
- task_name = port ,
203
- folder_name = folder_name ,
204
- callback_url = callback_url ,
205
- verbose = verbose ,
206
- progress_callback = progress_callback_upload ,
207
- simulation_type = simulation_type ,
208
- parent_tasks = parent_tasks ,
209
- solver_version = solver_version ,
210
- reduce_simulation = reduce_simulation ,
211
- )
212
- print (task_id_i )
213
- print (task_id_i_r )
214
- start (
215
- task_id_i ,
216
- solver_version = solver_version ,
217
- worker_group = worker_group ,
218
- pay_type = pay_type ,
219
- priority = priority ,
220
- )
221
- from ..core .http_util import http
222
-
195
+ # print(batch_task.batch_task_name_map)
196
+ # print(batch_task.batch_task_name_map.values())
197
+ # for port, task_id_i in batch_task.batch_task_name_map.items():
198
+ # simulation_i = modeler.sim_dict[port]
199
+ # task_id_i_r = upload(
200
+ # simulation=simulation_i,
201
+ # task_id=task_id_i,
202
+ # task_name=port,
203
+ # folder_name=folder_name,
204
+ # callback_url=callback_url,
205
+ # verbose=verbose,
206
+ # progress_callback=progress_callback_upload,
207
+ # simulation_type=simulation_type,
208
+ # parent_tasks=parent_tasks,
209
+ # solver_version=solver_version,
210
+ # reduce_simulation=reduce_simulation,
211
+ # )
212
+ # print(task_id_i)
213
+ # print(task_id_i_r)
214
+ # start(
215
+ # task_id_i,
216
+ # solver_version=solver_version,
217
+ # worker_group=worker_group,
218
+ # pay_type=pay_type,
219
+ # priority=priority,
220
+ # )
221
+ # from ..core.http_util import http
223
222
# print("batch_task.batch_id")
224
223
# print(batch_task.batch_id)
225
- # resp = http.post(
226
- # f"tidy3d/projects/{batch_task.batch_id}/batch-check",
227
- # {
228
- # "batchType": "RF_SWEEP",
229
- # "solverVersion": "dario-rf-0.0.0",
230
- # "protocolVersion": "2.10.0rc2"
231
- # },
232
- # )
233
- # print(resp)
234
- # resp = http.post(
235
- # f"tidy3d/projects/{batch_task.batch_id}/batch-submit",
236
- # {
237
- # "batchType": "RF_SWEEP",
238
- # "solverVersion": "dario-rf-0.0.0",
239
- # "protocolVersion": "2.10.0rc2"
240
- # },
241
- # )
224
+ resp = http .post (
225
+ f"tidy3d/projects/{ batch_task .batch_id } /batch-check" ,
226
+ {
227
+ "batchType" : "RF_SWEEP" ,
228
+ "solverVersion" : "dario-rf-0.0.0" ,
229
+ "protocolVersion" : "2.10.0rc2"
230
+ },
231
+ )
232
+ print (resp )
233
+ resp = http .post (
234
+ f"tidy3d/projects/{ batch_task .batch_id } /batch-submit" ,
235
+ {
236
+ "batchType" : "RF_SWEEP" ,
237
+ "solverVersion" : "dario-rf-0.0.0" ,
238
+ "protocolVersion" : "2.10.0rc2"
239
+ },
240
+ )
241
+ print (resp )
242
242
resp = http .get (
243
243
f"tidy3d/tasks/{ batch_task .batch_id } /batch-detail?batchType=RF_SWEEP" ,
244
244
{
@@ -249,13 +249,13 @@ def run(
249
249
)
250
250
print (resp )
251
251
from ..core .http_util import http
252
-
253
252
resp = http .post (
254
253
f"tidy3d/projects/{ batch_task .batch_id } /postprocess" ,
255
254
{
256
255
"batchType" : "RF_SWEEP" ,
257
256
"solverVersion" : "dario-rf-0.0.0" ,
258
257
"protocolVersion" : "2.10.0rc2" ,
258
+ "batchTaskNameMap" : batch_task .batch_task_name_map
259
259
},
260
260
)
261
261
print (resp )
0 commit comments