调整进程数量
This commit is contained in:
@@ -393,6 +393,11 @@ def cost_task(pk_phhd, cost_list):
|
||||
save_or_update_ie(ZxIeCost, pk_phhd, cost_data)
|
||||
|
||||
|
||||
def settlement_and_discharge_task(pk_phhd, settlement_list, discharge_record):
|
||||
settlement_task(pk_phhd, settlement_list)
|
||||
discharge_task(pk_phhd, discharge_record)
|
||||
|
||||
|
||||
def photo_review(pk_phhd):
|
||||
settlement_list = []
|
||||
discharge_record = []
|
||||
@@ -412,8 +417,9 @@ def photo_review(pk_phhd):
|
||||
cost_list.append(phrec)
|
||||
|
||||
with concurrent.futures.ProcessPoolExecutor() as executor:
|
||||
executor.submit(settlement_task, pk_phhd, settlement_list)
|
||||
executor.submit(discharge_task, pk_phhd, discharge_record)
|
||||
# executor.submit(settlement_task, pk_phhd, settlement_list)
|
||||
# executor.submit(discharge_task, pk_phhd, discharge_record)
|
||||
executor.submit(settlement_and_discharge_task, pk_phhd, settlement_list, discharge_record)
|
||||
executor.submit(cost_task, pk_phhd, cost_list)
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user