Fix double encode in create_schema (#52)

* schema * update test
v3io · Oct 12, 2020 · 3a7d9d9 · 3a7d9d9
1 parent b067baf
commit 3a7d9d9
Show file tree

Hide file tree

Showing 6 changed files with 8 additions and 8 deletions.
diff --git a/tests/test_client.py b/tests/test_client.py
@@ -321,7 +321,7 @@ def setUp(self):
         super(TestSchema, self).setUp()
 
         self._schema_dir = '/v3io-py-test-schema'
-        self._schema_path = os.path.join(self._schema_dir, '.%23schema')
+        self._schema_path = os.path.join(self._schema_dir, '.#schema')
 
         # clean up
         self._delete_dir(self._schema_dir)

diff --git a/tests/test_client_deprecated.py b/tests/test_client_deprecated.py
@@ -325,7 +325,7 @@ def setUp(self):
         super(TestSchema, self).setUp()
 
         self._schema_dir = '/v3io-py-test-schema'
-        self._schema_path = os.path.join(self._schema_dir, '.%23schema')
+        self._schema_path = os.path.join(self._schema_dir, '.#schema')
 
         # clean up
         self._delete_dir(self._schema_dir)

diff --git a/v3io/aio/dataplane/kv.py b/v3io/aio/dataplane/kv.py
@@ -338,7 +338,7 @@ async def create_schema(self,
         A `Response` object
         """
         put_object_args = locals()
-        put_object_args['path'] = os.path.join(put_object_args['table_path'], '.%23schema')
+        put_object_args['path'] = os.path.join(put_object_args['table_path'], '.#schema')
         put_object_args['offset'] = 0
         put_object_args['append'] = None
         put_object_args['body'] = self._client._get_schema_contents(key, fields)

diff --git a/v3io/dataplane/batch.py b/v3io/dataplane/batch.py
@@ -49,10 +49,10 @@ def __init__(self, client):
             ('stream', 'delete'),
             ('stream', 'describe'),
             ('stream', 'seek'),
-            ('stream', 'put'),
-            ('stream', 'get'),
+            ('stream', 'put_records'),
+            ('stream', 'get_records'),
             ('container', 'get'),
-            ('container', 'get_contents'),
+            ('container', 'list'),
         ]:
             setattr(getattr(self, model_name),
                     model_call,

diff --git a/v3io/dataplane/client.py b/v3io/dataplane/client.py
@@ -973,7 +973,7 @@ def create_schema(self,
         A `Response` object
         """
         put_object_args = locals()
-        put_object_args['path'] = os.path.join(put_object_args['path'], '.%23schema')
+        put_object_args['path'] = os.path.join(put_object_args['path'], '.#schema')
         put_object_args['offset'] = 0
         put_object_args['append'] = None
         put_object_args['body'] = self._get_schema_contents(key, fields)

diff --git a/v3io/dataplane/kv.py b/v3io/dataplane/kv.py
@@ -347,7 +347,7 @@ def create_schema(self,
         A `Response` object
         """
         put_object_args = locals()
-        put_object_args['path'] = os.path.join(put_object_args['table_path'], '.%23schema')
+        put_object_args['path'] = os.path.join(put_object_args['table_path'], '.#schema')
         put_object_args['offset'] = 0
         put_object_args['append'] = None
         put_object_args['body'] = self._client._get_schema_contents(key, fields)