在openspg上传数据分段执行时在第一个流程reader中就报错，这是为什么

[KsThk1]

unknown error PemjaUtils.invoke retry Exception uniqueKey:SPGServerBridge_028218046dc785df4dc0dd59fecd0246 2025-06-24 13:56:20(172.19.0.2): Task scheduling completed. cost:12 ms ! 2025-06-24 13:56:20(172.19.0.2): Lock released successfully! 2025-06-24 13:56:20(172.19.0.2): Scheduler execute failed with error:java.lang.RuntimeException: PemjaUtils.invoke retry Exception uniqueKey:SPGServerBridge_5891221e2b9d47205b7a9f1f77b56ec2 at com.antgroup.openspg.common.util.pemja.PemjaUtils.invoke(PemjaUtils.java:98) at com.antgroup.openspg.builder.core.physical.utils.CommonUtils.readSource(CommonUtils.java:211) at com.antgroup.openspg.server.core.scheduler.service.task.sync.builder.KagReaderSyncTask.readSource(KagReaderSyncTask.java:72) at com.antgroup.openspg.server.core.scheduler.service.task.sync.builder.KagReaderSyncTask.submit(KagReaderSyncTask.java:51) at com.antgroup.openspg.server.core.scheduler.service.task.sync.SyncTaskExecuteTemplate.execute(SyncTaskExecuteTemplate.java:25) at com.antgroup.openspg.server.core.scheduler.service.task.TaskExecuteTemplate.executeEntry(TaskExecuteTemplate.java:53) at com.antgroup.openspg.server.core.scheduler.service.engine.impl.SchedulerExecuteServiceImpl.executeTask(SchedulerExecuteServiceImpl.java:161) at com.antgroup.openspg.server.core.scheduler.service.engine.impl.SchedulerExecuteServiceImpl.lambda$executeInstance$2(SchedulerExecuteServiceImpl.java:144) at java.util.ArrayList.forEach(ArrayList.java:1259) at com.antgroup.openspg.server.core.scheduler.service.engine.impl.SchedulerExecuteServiceImpl.executeInstance(SchedulerExecuteServiceImpl.java:144) at com.antgroup.openspg.server.core.scheduler.service.engine.impl.SchedulerExecuteServiceImpl.executeInstance(SchedulerExecuteServiceImpl.java:132) at com.antgroup.openspg.server.core.scheduler.service.engine.impl.SchedulerExecuteServiceImpl.lambda$executeInstances$0(SchedulerExecuteServiceImpl.java:104) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:750) Caused by: pemja.core.PythonException: <class 'AttributeError'>: 'ProjectClient' object has no attribute 'get_by_id' at .(:1) at /home/admin/miniconda3/lib/python3.10/site-packages/kag/bridge/spg_server_bridge.init_kag_config(spg_server_bridge.py:26) at /home/admin/miniconda3/lib/python3.10/site-packages/kag/common/conf.init_env(conf.py:202) at /home/admin/miniconda3/lib/python3.10/site-packages/kag/common/conf.initialize(conf.py:168) at /home/admin/miniconda3/lib/python3.10/site-packages/kag/common/conf.load_config(conf.py:116) at pemja.core.PythonInterpreter.exec(Native Method) at pemja.core.PythonInterpreter.exec(PythonInterpreter.java:125) at com.antgroup.openspg.common.util.pemja.PemjaUtils.getPythonInterpreter(PemjaUtils.java:115) at com.antgroup.openspg.common.util.pemja.PemjaUtils.invoke(PemjaUtils.java:53) ... 14 more

2025-06-24 13:56:20(172.19.0.2): Invoke read operator:run_reader 2025-06-24 13:56:20(172.19.0.2): Lock preempted successfully!

2025-06-24 13:55:20(172.19.0.2): Task scheduling completed. cost:15 ms ! 2025-06-24 13:55:20(172.19.0.2): Lock released successfully! 2025-06-24 13:55:20(172.19.0.2): Scheduler execute failed with error:java.lang.RuntimeException: PemjaUtils.invoke retry Exception uniqueKey:SPGServerBridge_9e070e5eeddf76a67701742e30173278 at com.antgroup.openspg.common.util.pemja.PemjaUtils.invoke(PemjaUtils.java:98) at com.antgroup.openspg.builder.core.physical.utils.CommonUtils.readSource(CommonUtils.java:211) at com.antgroup.openspg.server.core.scheduler.service.task.sync.builder.KagReaderSyncTask.readSource(KagReaderSyncTask.java:72) at com.antgroup.openspg.server.core.scheduler.service.task.sync.builder.KagReaderSyncTask.submit(KagReaderSyncTask.java:51) at com.antgroup.openspg.server.core.scheduler.service.task.sync.SyncTaskExecuteTemplate.execute(SyncTaskExecuteTemplate.java:25) at com.antgroup.openspg.server.core.scheduler.service.task.TaskExecuteTemplate.executeEntry(TaskExecuteTemplate.java:53) at com.antgroup.openspg.server.core.scheduler.service.engine.impl.SchedulerExecuteServiceImpl.executeTask(SchedulerExecuteServiceImpl.java:161) at com.antgroup.openspg.server.core.scheduler.service.engine.impl.SchedulerExecuteServiceImpl.lambda$executeInstance$2(SchedulerExecuteServiceImpl.java:144) at java.util.ArrayList.forEach(ArrayList.java:1259) at com.antgroup.openspg.server.core.scheduler.service.engine.impl.SchedulerExecuteServiceImpl.executeInstance(SchedulerExecuteServiceImpl.java:144) at com.antgroup.openspg.server.core.scheduler.service.engine.impl.SchedulerExecuteServiceImpl.executeInstance(SchedulerExecuteServiceImpl.java:132) at com.antgroup.openspg.server.core.scheduler.service.engine.impl.SchedulerExecuteServiceImpl.lambda$executeInstances$0(SchedulerExecuteServiceImpl.java:104) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:750) Caused by: pemja.core.PythonException: <class 'AttributeError'>: 'ProjectClient' object has no attribute 'get_by_id' at .(:1) at /home/admin/miniconda3/lib/python3.10/site-packages/kag/bridge/spg_server_bridge.init_kag_config(spg_server_bridge.py:26) at /home/admin/miniconda3/lib/python3.10/site-packages/kag/common/conf.init_env(conf.py:202) at /home/admin/miniconda3/lib/python3.10/site-packages/kag/common/conf.initialize(conf.py:168) at /home/admin/miniconda3/lib/python3.10/site-packages/kag/common/conf.load_config(conf.py:116) at pemja.core.PythonInterpreter.exec(Native Method) at pemja.core.PythonInterpreter.exec(PythonInterpreter.java:125) at com.antgroup.openspg.common.util.pemja.PemjaUtils.getPythonInterpreter(PemjaUtils.java:115) at com.antgroup.openspg.common.util.pemja.PemjaUtils.invoke(PemjaUtils.java:53) ... 14 more

2025-06-24 13:55:20(172.19.0.2): Invoke read operator:run_reader 2025-06-24 13:55:20(172.19.0.2): Lock preempted successfully!