Skip to content

Commit abd00b6

Browse files
committed
Fix KafkaTopic.from_reposnse_json
1 parent 0e8c87c commit abd00b6

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

python/hopsworks_common/kafka_topic.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -99,11 +99,11 @@ def _validate_topic_config(cls, name, num_replicas, num_partitions):
9999
def from_response_json(cls, json_dict):
100100
json_decamelized = humps.decamelize(json_dict)
101101
if "count" not in json_decamelized:
102-
return cls(**json_decamelized)
102+
return cls.from_json(json_decamelized)
103103
elif json_decamelized["count"] == 0:
104104
return []
105105
else:
106-
return [cls(**kafka_topic) for kafka_topic in json_decamelized["items"]]
106+
return [cls.from_json(jd) for jd in json_decamelized["items"]]
107107

108108
@classmethod
109109
def from_json(cls, json_decamelized):

0 commit comments

Comments
 (0)