guohanghui commited on
Commit
e05aab3
·
verified ·
1 Parent(s): ce55036

Update pyPDAF/mcp_output/mcp_plugin/mcp_service.py

Browse files
pyPDAF/mcp_output/mcp_plugin/mcp_service.py CHANGED
@@ -521,11 +521,11 @@ def run_enoi_pipeline(
521
  loc_handler = LocalizationHandler()
522
 
523
  # Run offline assimilation with localization
 
 
524
  try:
525
  status = 0
526
  pyPDAF.assim_offline_local_nondiagr(
527
- collector.collect_state_pdaf,
528
- collector.distribute_state_pdaf,
529
  obs_handler.init_dim_obs_pdafomi,
530
  obs_handler.obs_op_pdafomi,
531
  collector.prepoststep_pdaf,
@@ -538,11 +538,11 @@ def run_enoi_pipeline(
538
  return {"status": "error", "message": f"Localized assimilation failed: {str(e)}"}
539
  else:
540
  # Run without localization (global filter)
 
 
541
  try:
542
  status = 0
543
  pyPDAF.assim_offline_global_nondiagr(
544
- collector.collect_state_pdaf,
545
- collector.distribute_state_pdaf,
546
  obs_handler.init_dim_obs_pdafomi,
547
  obs_handler.obs_op_pdafomi,
548
  collector.prepoststep_pdaf,
 
521
  loc_handler = LocalizationHandler()
522
 
523
  # Run offline assimilation with localization
524
+ # For PDAF V3.0, assim_offline_local_nondiagr expects 7 arguments:
525
+ # (init_dim_obs, obs_op, prepoststep, init_n_domains, init_dim_l, init_dim_obs_l, status)
526
  try:
527
  status = 0
528
  pyPDAF.assim_offline_local_nondiagr(
 
 
529
  obs_handler.init_dim_obs_pdafomi,
530
  obs_handler.obs_op_pdafomi,
531
  collector.prepoststep_pdaf,
 
538
  return {"status": "error", "message": f"Localized assimilation failed: {str(e)}"}
539
  else:
540
  # Run without localization (global filter)
541
+ # For PDAF V3.0, assim_offline_global_nondiagr expects 4 arguments:
542
+ # (init_dim_obs, obs_op, prepoststep, status)
543
  try:
544
  status = 0
545
  pyPDAF.assim_offline_global_nondiagr(
 
 
546
  obs_handler.init_dim_obs_pdafomi,
547
  obs_handler.obs_op_pdafomi,
548
  collector.prepoststep_pdaf,