k8s: Add a parameter remote_src

remote_src is boolean parameter to specify if
src file is located on remote node or Ansible Controller.

Fixes: ansible-collections#307

Signed-off-by: Abhijeet Kasurde <akasurde@redhat.com>

changelogs/fragments/307_remote_src.yml

@@ -0,0 +1,2 @@
+minor_changes:
+- k8s - add parameter to specify if src file is located on remote node and not on Ansible Controller (https://github.com/ansible-collections/community.kubernetes/issues/307).

plugins/action/k8s_info.py

@@ -62,7 +62,14 @@ def run(self, tmp=None, task_vars=None):
 
         # find the file in the expected search path
         src = self._task.args.get('src', None)
+        remote_src = self._task.args.get('remote_src', False)
+
         if src:
+            if remote_src:
+                # src is on remote node
+                result.update(self._execute_module(module_name=self._task.action, task_vars=task_vars))
+                return self._ensure_invocation(result)
+
             try:
                 # find in expected paths
                 src = self._find_needle('files', src)
@@ -117,10 +124,6 @@ def run(self, tmp=None, task_vars=None):
             else:
                 raise AnsibleActionFail("Error while reading template file - "
                                         "a string or dict for template expected, but got %s instead" % type(template))
-            try:
-                source = self._find_needle('templates', template_path)
-            except AnsibleError as e:
-                raise AnsibleActionFail(to_text(e))
 
             # Option `lstrip_blocks' was added in Jinja2 version 2.7.
             if lstrip_blocks:
@@ -143,6 +146,11 @@ def run(self, tmp=None, task_vars=None):
             elif newline_sequence not in allowed_sequences:
                 raise AnsibleActionFail("newline_sequence needs to be one of: \n, \r or \r\n")
 
+            try:
+                source = self._find_needle('templates', template_path)
+            except AnsibleError as e:
+                raise AnsibleActionFail(to_text(e))
+
             # Get vault decrypted tmp file
             try:
                 tmp_source = self._loader.get_real_file(source)

plugins/doc_fragments/k8s_resource_options.py

@@ -30,4 +30,11 @@ class ModuleDocFragment(object):
       I(resource_definition). See Examples below.
     - Mutually exclusive with I(template) in case of M(k8s) module.
     type: path
+  remote_src:
+    description:
+    - Set to C(yes) to indicate the I(src) file is already on the remote system and not local to the Ansible controller.
+    - This is not valid for I(template) parameter.
+    type: bool
+    default: False
+    version_added: "1.2.0"
 '''

plugins/module_utils/common.py

@@ -125,6 +125,10 @@ def list_dict_str(value):
     'src': {
         'type': 'path',
     },
+    'remote_src': {
+        'type': 'bool',
+        'default': False,
+    },
 }
 
 NAME_ARG_SPEC = {

tests/integration/targets/kubernetes/tasks/main.yml

@@ -17,6 +17,7 @@
     name:
       - openshift>=0.9.2
       - coverage
+    extra_args: "--use-deprecated=legacy-resolver"
     virtualenv: "{{ virtualenv }}"
     virtualenv_command: "{{ virtualenv_command }}"
     virtualenv_site_packages: no
@@ -37,6 +38,7 @@
       - kubernetes-validate==1.12.0
       - openshift>=0.9.2
       - coverage
+    extra_args: "--use-deprecated=legacy-resolver"
     virtualenv: "{{ virtualenv }}"
     virtualenv_command: "{{ virtualenv_command }}"
     virtualenv_site_packages: no
@@ -58,6 +60,7 @@
       - kubernetes==12.0.0
       - openshift>=0.9.2
       - coverage
+    extra_args: "--use-deprecated=legacy-resolver"
     virtualenv: "{{ virtualenv }}"
     virtualenv_command: "{{ virtualenv_command }}"
     virtualenv_site_packages: no
@@ -73,7 +76,6 @@
   no_log: yes
 
 # Test openshift
-
 - debug:
     var: k8s_openshift