Search before asking

• I had searched in the issues and found no similar issues.

Operating system information

Linux

What happened

[Scanner]: There are total 1 data to process, worker 0/1 will process range [0, 1)
Existing checkpoint found in ckpt/DictReader, with 2 records.
Existing checkpoint found in ckpt/LengthSplitter, with 2 records.
Existing checkpoint found in ckpt/SummaryExtractor, with 7 records.
Existing checkpoint found in ckpt/SchemaConstraintExtractor, with 7 records.
Existing checkpoint found in ckpt/BatchVectorizer, with 7 records.
Traceback (most recent call last):
File "/mnt/HDD0/home/zxy24/KAG/kag/builder/runner.py", line 207, in process
result = await self.chain.ainvoke(data)
File "/mnt/HDD0/home/zxy24/KAG/kag/interface/builder/builder_chain_abc.py", line 164, in ainvoke
outputs = await asyncio.gather(*tasks)
File "/mnt/HDD0/home/zxy24/KAG/kag/interface/builder/builder_chain_abc.py", line 134, in execute_node
results = await asyncio.gather(*tasks)
File "/mnt/HDD0/home/zxy24/KAG/kag/interface/builder/builder_chain_abc.py", line 126, in ainvoke_with_semaphore
return await node.ainvoke(item)
File "/mnt/HDD0/home/zxy24/KAG/kag/interface/builder/base.py", line 215, in ainvoke
output = await self._ainvoke(input_data, **kwargs)
File "/mnt/HDD0/home/zxy24/KAG/kag/builder/component/vectorizer/batch_vectorizer.py", line 496, in _ainvoke
modified_input = await self._agenerate_embedding_vectors(input_subgraph)
File "/mnt/HDD0/home/zxy24/miniconda3/envs/openspg/lib/python3.10/site-packages/tenacity/asyncio/init.py", line 193, in async_wrapped
return await copy(fn, *args, **kwargs)
File "/mnt/HDD0/home/zxy24/miniconda3/envs/openspg/lib/python3.10/site-packages/tenacity/asyncio/init.py", line 112, in call
do = await self.iter(retry_state=retry_state)
File "/mnt/HDD0/home/zxy24/miniconda3/envs/openspg/lib/python3.10/site-packages/tenacity/asyncio/init.py", line 157, in iter
result = await action(retry_state)
File "/mnt/HDD0/home/zxy24/miniconda3/envs/openspg/lib/python3.10/site-packages/tenacity/_utils.py", line 111, in inner
return call(*args, **kwargs)
File "/mnt/HDD0/home/zxy24/miniconda3/envs/openspg/lib/python3.10/site-packages/tenacity/init.py", line 413, in exc_check
raise retry_exc.reraise()
File "/mnt/HDD0/home/zxy24/miniconda3/envs/openspg/lib/python3.10/site-packages/tenacity/init.py", line 184, in reraise
raise self.last_attempt.result()
File "/mnt/HDD0/home/zxy24/miniconda3/envs/openspg/lib/python3.10/concurrent/futures/_base.py", line 451, in result
return self.__get_result()
File "/mnt/HDD0/home/zxy24/miniconda3/envs/openspg/lib/python3.10/concurrent/futures/_base.py", line 403, in __get_result
raise self._exception
File "/mnt/HDD0/home/zxy24/miniconda3/envs/openspg/lib/python3.10/site-packages/tenacity/asyncio/init.py", line 116, in call
result = await fn(*args, **kwargs)
File "/mnt/HDD0/home/zxy24/KAG/kag/builder/component/vectorizer/batch_vectorizer.py", line 461, in _agenerate_embedding_vectors
await generator.abatch_generate(node_batch, self.batch_size)
File "/mnt/HDD0/home/zxy24/KAG/kag/builder/component/vectorizer/batch_vectorizer.py", line 322, in abatch_generate
await manager.abatch_generate_dense(self._vectorizer, batch_size)
File "/mnt/HDD0/home/zxy24/KAG/kag/builder/component/vectorizer/batch_vectorizer.py", line 233, in abatch_generate_dense
vectors = await self._agenerate_dense_vectors(
File "/mnt/HDD0/home/zxy24/KAG/kag/builder/component/vectorizer/batch_vectorizer.py", line 183, in _agenerate_dense_vectors
return [item for sublist in results for item in sublist]
File "/mnt/HDD0/home/zxy24/KAG/kag/builder/component/vectorizer/batch_vectorizer.py", line 183, in
return [item for sublist in results for item in sublist]
TypeError: 'NoneType' object is not iterable

How to reproduce

[Scanner]: There are total 1 data to process, worker 0/1 will process range [0, 1)
Existing checkpoint found in ckpt/DictReader, with 2 records.
Existing checkpoint found in ckpt/LengthSplitter, with 2 records.
Existing checkpoint found in ckpt/SummaryExtractor, with 7 records.
Existing checkpoint found in ckpt/SchemaConstraintExtractor, with 7 records.
Existing checkpoint found in ckpt/BatchVectorizer, with 7 records.
Traceback (most recent call last):
File "/mnt/HDD0/home/zxy24/KAG/kag/builder/runner.py", line 207, in process
result = await self.chain.ainvoke(data)
File "/mnt/HDD0/home/zxy24/KAG/kag/interface/builder/builder_chain_abc.py", line 164, in ainvoke
outputs = await asyncio.gather(*tasks)
File "/mnt/HDD0/home/zxy24/KAG/kag/interface/builder/builder_chain_abc.py", line 134, in execute_node
results = await asyncio.gather(*tasks)
File "/mnt/HDD0/home/zxy24/KAG/kag/interface/builder/builder_chain_abc.py", line 126, in ainvoke_with_semaphore
return await node.ainvoke(item)
File "/mnt/HDD0/home/zxy24/KAG/kag/interface/builder/base.py", line 215, in ainvoke
output = await self._ainvoke(input_data, **kwargs)
File "/mnt/HDD0/home/zxy24/KAG/kag/builder/component/vectorizer/batch_vectorizer.py", line 496, in _ainvoke
modified_input = await self._agenerate_embedding_vectors(input_subgraph)
File "/mnt/HDD0/home/zxy24/miniconda3/envs/openspg/lib/python3.10/site-packages/tenacity/asyncio/init.py", line 193, in async_wrapped
return await copy(fn, *args, **kwargs)
File "/mnt/HDD0/home/zxy24/miniconda3/envs/openspg/lib/python3.10/site-packages/tenacity/asyncio/init.py", line 112, in call
do = await self.iter(retry_state=retry_state)
File "/mnt/HDD0/home/zxy24/miniconda3/envs/openspg/lib/python3.10/site-packages/tenacity/asyncio/init.py", line 157, in iter
result = await action(retry_state)
File "/mnt/HDD0/home/zxy24/miniconda3/envs/openspg/lib/python3.10/site-packages/tenacity/_utils.py", line 111, in inner
return call(*args, **kwargs)
File "/mnt/HDD0/home/zxy24/miniconda3/envs/openspg/lib/python3.10/site-packages/tenacity/init.py", line 413, in exc_check
raise retry_exc.reraise()
File "/mnt/HDD0/home/zxy24/miniconda3/envs/openspg/lib/python3.10/site-packages/tenacity/init.py", line 184, in reraise
raise self.last_attempt.result()
File "/mnt/HDD0/home/zxy24/miniconda3/envs/openspg/lib/python3.10/concurrent/futures/_base.py", line 451, in result
return self.__get_result()
File "/mnt/HDD0/home/zxy24/miniconda3/envs/openspg/lib/python3.10/concurrent/futures/_base.py", line 403, in __get_result
raise self._exception
File "/mnt/HDD0/home/zxy24/miniconda3/envs/openspg/lib/python3.10/site-packages/tenacity/asyncio/init.py", line 116, in call
result = await fn(*args, **kwargs)
File "/mnt/HDD0/home/zxy24/KAG/kag/builder/component/vectorizer/batch_vectorizer.py", line 461, in _agenerate_embedding_vectors
await generator.abatch_generate(node_batch, self.batch_size)
File "/mnt/HDD0/home/zxy24/KAG/kag/builder/component/vectorizer/batch_vectorizer.py", line 322, in abatch_generate
await manager.abatch_generate_dense(self._vectorizer, batch_size)
File "/mnt/HDD0/home/zxy24/KAG/kag/builder/component/vectorizer/batch_vectorizer.py", line 233, in abatch_generate_dense
vectors = await self._agenerate_dense_vectors(
File "/mnt/HDD0/home/zxy24/KAG/kag/builder/component/vectorizer/batch_vectorizer.py", line 183, in _agenerate_dense_vectors
return [item for sublist in results for item in sublist]
File "/mnt/HDD0/home/zxy24/KAG/kag/builder/component/vectorizer/batch_vectorizer.py", line 183, in
return [item for sublist in results for item in sublist]
TypeError: 'NoneType' object is not iterable

Are you willing to submit PR?

• Yes I am willing to submit a PR!