Commit 8c9bc355 authored by 段英荣's avatar 段英荣

modify topic transfer

parent 452a3aeb
...@@ -149,12 +149,21 @@ class TableSlicerChunk(ITableChunk): ...@@ -149,12 +149,21 @@ class TableSlicerChunk(ITableChunk):
class TableSlicer(object): class TableSlicer(object):
def __init__(self, queryset, chunk_size=None, chunk_count=None, sep_list=None): def __init__(self, queryset, chunk_size=None, chunk_count=None, sep_list=None):
logging.info("duan add,before assert queryset")
assert isinstance(queryset, models.QuerySet) assert isinstance(queryset, models.QuerySet)
logging.info("duan add,before assert chunk_size")
assert chunk_size is None or isinstance(chunk_size, six.integer_types) assert chunk_size is None or isinstance(chunk_size, six.integer_types)
logging.info("duan add,before assert chunk_count")
assert chunk_count is None or isinstance(chunk_count, six.integer_types) assert chunk_count is None or isinstance(chunk_count, six.integer_types)
logging.info("duan add,before assert sep_list")
assert sep_list is None or isinstance(sep_list, list) assert sep_list is None or isinstance(sep_list, list)
logging.info("duan add,before assert chunk_size")
assert (chunk_size is not None) + (chunk_count is not None) + (sep_list is not None) == 1 assert (chunk_size is not None) + (chunk_count is not None) + (sep_list is not None) == 1
logging.info("duan add,after assert chunk_size")
if sep_list is not None: if sep_list is not None:
sep_list = list(sep_list) sep_list = list(sep_list)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment