Description
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!