in datahub/models/results.py [0:0]
def parse_content(cls, content, **kwargs):
content = json.loads(to_text(content))
cluster_addr = content.get('ClusterAddress', '')
connector_id = content.get('ConnectorId', '')
connector_type = ConnectorType(content['Type'])
state = ConnectorState(content['State'])
creator = content.get('Creator', '')
owner = content.get('Owner', '')
create_time = content.get('CreateTime', 0)
column_fields = content.get('ColumnFields', [])
connector_config = get_connector_builder_by_type(connector_type).from_dict(content['Config'])
extra_config = content.get('ExtraInfo', {})
shard_contexts = [ShardContext.from_dict(item) for item in content['ShardContexts']] # deprecated
sub_id = extra_config.get('SubscriptionId', '')
return cls(cluster_addr, connector_id, connector_type, state, creator, owner, create_time, column_fields,
connector_config, extra_config, shard_contexts, sub_id)