ansible/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2024-09-14 20:13:21 +02:00
Code Releases Activity

Adds datetime encoder. Fixes Service comparison. (#34223)

Browse source
This commit is contained in:
Chris Houseknecht 2017-12-25 12:09:31 -05:00 committed by GitHub
parent f1bda19dea
commit 54396a95c2
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 12 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
lib/ansible/module_utils/k8s/common.py
View file

@ -21,6 +21,9 @@ from __future__ import absolute_import, division, print_function
import os import os
import re import re
import copy import copy
import json
from datetime import datetime
from ansible.module_utils.six import iteritems from ansible.module_utils.six import iteritems
from ansible.module_utils.basic import AnsibleModule from ansible.module_utils.basic import AnsibleModule
@ -53,6 +56,14 @@ except ImportError:
HAS_YAML = False HAS_YAML = False
class DateTimeEncoder(json.JSONEncoder):
# When using json.dumps() with K8s object, pass cls=DateTimeEncoder to handle any datetime objects
def default(self, o):
if isinstance(o, datetime):
return o.isoformat()
return json.JSONEncoder.default(self, o)
class KubernetesAnsibleModuleHelper(AnsibleMixin, KubernetesObjectHelper): class KubernetesAnsibleModuleHelper(AnsibleMixin, KubernetesObjectHelper):
pass pass
@ -196,7 +207,7 @@ class KubernetesAnsibleModule(AnsibleModule):
self.helper.object_from_params(self.params, obj=k8s_obj) self.helper.object_from_params(self.params, obj=k8s_obj)
except KubernetesException as exc: except KubernetesException as exc:
self.fail_json(msg="Failed to patch object: {0}".format(exc.message)) self.fail_json(msg="Failed to patch object: {0}".format(exc.message))
match, diff = self.helper.objects_match(existing, k8s_obj) match, diff = self.helper.objects_match(self.helper.fix_serialization(existing), k8s_obj)
if match: if match:
return_attributes['result'] = existing.to_dict() return_attributes['result'] = existing.to_dict()
self.exit_json(**return_attributes) self.exit_json(**return_attributes)