Fix a few tests

common/cpp/include/asapo/request/broker_request.h

@@ -88,7 +88,6 @@ namespace asapo
         std::string endpoint_;
         SourceCredentials source_credentials_;
         std::string data_source_encoded_;
-        bool use_new_api_format_ = true;
         std::string current_broker_uri_;
 
     };

common/cpp/src/request/broker_request.cpp

@@ -310,12 +310,9 @@ namespace asapo
 
         RequestInfo ri;
         ri.api = uri;
+        ri.extra_params += "&instanceid=" + httpclient__->UrlEscape(source_credentials_.instance_id);
+        ri.extra_params += "&pipelinestep=" + httpclient__->UrlEscape(source_credentials_.pipeline_step);
 
-        if (use_new_api_format_)
-        {
-            ri.extra_params += "&instanceid=" + httpclient__->UrlEscape(source_credentials_.instance_id);
-            ri.extra_params += "&pipelinestep=" + httpclient__->UrlEscape(source_credentials_.pipeline_step);
-        }
         return ri;
     }
 

producer/api/python/asapo_producer.pxd

@@ -24,6 +24,9 @@ cdef extern from "asapo/asapo_producer.h" namespace "asapo":
   ErrorTemplateInterface kRequestPoolIsFull "asapo::ProducerErrorTemplates::kRequestPoolIsFull"
   ErrorTemplateInterface kUnsupportedClient "asapo::ProducerErrorTemplates::kUnsupportedClient"
 
+cdef extern from "asapo/request/consumer_error.h" namespace "asapo":
+  ErrorTemplateInterface kWrongConsumerInput "asapo::ConsumerErrorTemplates::kWrongInput"
+
 cdef extern from "asapo/asapo_producer.h" namespace "asapo":
   cppclass MessageData:
     uint8_t[] release()

producer/api/python/asapo_producer.pyx.in

@@ -75,6 +75,8 @@ cdef python_exception_from_error(Error& err):
                 return AsapoTimeOutError(error_string)
     elif err == kWrongInput:
             return AsapoWrongInputError(error_string)
+    elif err == kWrongConsumerInput:
+            return AsapoWrongInputError(error_string)           
     elif err == kLocalIOError:
             return AsapoLocalIOError(error_string)
     elif err == kServerWarning: