Testing

Author: krishung5

src/python_be.cc

@@ -1303,6 +1303,14 @@ ModelInstanceState::ResponseSendDecoupled(
     SetErrorForResponseSendMessage(
         send_message_payload, WrapTritonErrorInSharedPtr(error), error_message);
   }
+
+  if (send_message_payload->flags == TRITONSERVER_RESPONSE_COMPLETE_FINAL) {
+    // Delete response factory
+    std::unique_ptr<
+        TRITONBACKEND_ResponseFactory, backend::ResponseFactoryDeleter>
+        response_factory(reinterpret_cast<TRITONBACKEND_ResponseFactory*>(
+            send_message_payload->response_factory_address));
+  }
 }
 
 TRITONSERVER_Error*

src/response_sender.cc

@@ -47,10 +47,11 @@ ResponseSender::ResponseSender(
 
 ResponseSender::~ResponseSender()
 {
-  std::unique_ptr<Stub>& stub = Stub::GetOrCreateInstance();
-  stub->EnqueueCleanupId(
-      reinterpret_cast<void*>(response_factory_address_),
-      PYTHONSTUB_DecoupledResponseFactoryCleanup);
+  // std::cerr << "===== ResponseSender::~ResponseSender() =====" << std::endl;
+  // std::unique_ptr<Stub>& stub = Stub::GetOrCreateInstance();
+  // stub->EnqueueCleanupId(
+  //     reinterpret_cast<void*>(response_factory_address_),
+  //     PYTHONSTUB_DecoupledResponseFactoryCleanup);
 }
 
 void