Commit 24da12cc authored by ibuler's avatar ibuler

[Update] 修改一处小bug

parent 66f4e83c
......@@ -269,8 +269,9 @@ class S3ReplayRecorder(ServerReplayRecorder):
def get_command_recorder_class(config):
command_storage = config["COMMAND_STORAGE"]
storage_type = command_storage.get('TYPE')
if command_storage.get('TYPE') == "elasticsearch":
if storage_type == "elasticsearch":
return ESCommandRecorder
else:
return ServerCommandRecorder
......@@ -278,7 +279,8 @@ def get_command_recorder_class(config):
def get_replay_recorder_class(config):
replay_storage = config["REPLAY_STORAGE"]
if replay_storage.get('TYPE') == "s3":
storage_type = replay_storage.get('TYPE')
if storage_type == "s3":
return S3ReplayRecorder
else:
return ServerReplayRecorder
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