| |
@@ -29,11 +29,11 @@
|
| |
return re.sub('([a-z0-9])([A-Z])', r'\1.\2', s1).lower()
|
| |
|
| |
|
| |
- def serialize_datetime_in_task(task):
|
| |
+ def serialize_datetime(msg):
|
| |
for date_key in ("completion_time", "create_time", "start_time"):
|
| |
- if task[date_key] is None:
|
| |
+ if msg.get(date_key) is None:
|
| |
continue
|
| |
- task[date_key] = time.mktime(task[date_key].timetuple())
|
| |
+ msg[date_key] = time.mktime(msg[date_key].timetuple())
|
| |
|
| |
|
| |
def get_message_body(topic, *args, **kws):
|
| |
@@ -53,7 +53,6 @@
|
| |
msg['update'] = kws.get('update', None)
|
| |
elif topic == 'task.state.change':
|
| |
info = kws['info']
|
| |
- serialize_datetime_in_task(info)
|
| |
|
| |
# Stuff in information about descendant tasks
|
| |
task = kojihub.Task(info['id'])
|
| |
@@ -149,6 +148,8 @@
|
| |
msg['build'] = kws['build']
|
| |
msg['rpm'] = kws['rpm']
|
| |
|
| |
+ serialize_datetime(msg)
|
| |
+
|
| |
return msg
|
| |
|
| |
|
| |
pingou
commented 4 years ago
Basically, we should check for every message we are trying to send
if they contain dates and if they do serialize them.
But since we're not sure if they do, we need to be more careful when
checking it.
Signed-off-by: Pierre-Yves Chibon pingou@pingoured.fr