Revision bb80a8d7
b/snf-cyclades-app/synnefo/logic/callbacks.py | ||
---|---|---|
131 | 131 |
""" |
132 | 132 |
@wraps(func) |
133 | 133 |
def wrapper(target, msg): |
134 |
event_time = merge_time(msg['event_time']) |
|
134 |
try: |
|
135 |
event_time = merge_time(msg['event_time']) |
|
136 |
except: |
|
137 |
log.error("Received message with malformed time: %s", |
|
138 |
msg['event_time']) |
|
139 |
raise KeyError |
|
140 |
|
|
135 | 141 |
db_time = target.backendtime |
136 | 142 |
|
137 | 143 |
if db_time and event_time <= db_time: |
Also available in: Unified diff