psi support retry

Author: cyjseagull

cpp/wedpr-transport/ppc-rpc/src/RpcMemory.cpp

@@ -72,9 +72,15 @@ void RpcMemory::cleanTask()
 bcos::Error::Ptr RpcMemory::insertTask(protocol::Task::Ptr _task)
 {
     WriteGuard l(x_tasks);
-    if (m_tasks.find(_task->id()) != m_tasks.end())
+    auto it = m_tasks.find(_task->id());
+    if (it != m_tasks.end())
     {
-        return std::make_shared<bcos::Error>(PPCRetCode::WRITE_RPC_STATUS_ERROR, "task exists");
+        auto taskResult = it->second.second;
+        // the task already exists case
+        if (!taskResult || taskResult->status() == toString(TaskStatus::RUNNING))
+        {
+            return std::make_shared<bcos::Error>(PPCRetCode::WRITE_RPC_STATUS_ERROR, "task exists");
+        }
     }
     auto taskResult = std::make_shared<TaskResult>(_task->id());
     taskResult->setStatus(toString(TaskStatus::RUNNING));