Implement unit test framework with initial unit tests.

Author: Patrick J. McNerthney

.github/workflows/ci.yaml

@@ -48,27 +48,27 @@ jobs:
   #         python-version: ${{ env.PYTHON_VERSION }}
 
   #     - name: Setup Hatch
-  #       run: pipx install hatch==1.7.0
+  #       run: pipx install hatch==1.14.1
 
   #     - name: Lint
   #       run: hatch run lint:check
 
-  # unit-test:
-  #   runs-on: ubuntu-24.04
-  #   steps:
-  #     - name: Checkout
-  #       uses: actions/checkout@v4
+  unit-test:
+    runs-on: ubuntu-24.04
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v4
 
-  #     - name: Setup Python
-  #       uses: actions/setup-python@v5
-  #       with:
-  #         python-version: ${{ env.PYTHON_VERSION }}
+      - name: Setup Python
+        uses: actions/setup-python@v5
+        with:
+          python-version: ${{ env.PYTHON_VERSION }}
 
-  #     - name: Setup Hatch
-  #       run: pipx install hatch==1.7.0
+      - name: Setup Hatch
+        run: pipx install hatch==1.14.1
 
-  #     - name: Run Unit Tests
-  #       run: hatch run test:unit
+      - name: Run Unit Tests
+        run: hatch run test:unit
 
   # We want to build most packages for the amd64 and arm64 architectures. To
   # speed this up we build single-platform packages in parallel. We then upload

examples/function-go-templating/inline/composition.yaml

@@ -23,7 +23,7 @@ spec:
               user = f"test-user-{ix}"
               r = self.resources[user]('iam.aws.upbound.io/v1beta1', 'User')
               r.metadata.labels['testing.upbound.io/example-name'] = user
-              r.metadata.labels.dummy = r.observed.resource.metadata.labels.dummy or random.choice(['foo', 'bar', 'baz'])
+              r.metadata.labels.dummy = r.observed.metadata.labels.dummy or random.choice(['foo', 'bar', 'baz'])
               r = self.resources[f"sample-access-key-{ix}"]('iam.aws.upbound.io/v1beta1', 'AccessKey')
               r.spec.forProvider.userSelector.matchLabels['testing.upbound.io/example-name'] = user
               r.spec.writeConnectionSecretToRef.namespace = 'crossplane.system'

examples/inline/functions.yaml examples/single-purpose/functions.yamlexamples/inline/functions.yaml renamed to examples/single-purpose/functions.yaml

@@ -54,7 +54,7 @@ def ready(self):
     def ready(self, ready):
         if ready:
             ready = fnv1.Ready.READY_TRUE
-        elif ready == None or (isinstance(ready, function.protobuf.Values) and ready._type == function.protobuf.Values.Type.UNKNOWN):
+        elif ready == None or (isinstance(ready, function.protobuf.Values) and ready._isUnknown):
             ready = fnv1.Ready.READY_UNSPECIFIED
         else:
             ready = fnv1.Ready.READY_FALSE
@@ -209,7 +209,7 @@ def ready(self):
     def ready(self, ready):
         if ready:
             ready = fnv1.Ready.READY_TRUE
-        elif ready == None or (isinstance(ready, function.protobuf.Values) and ready._type == function.protobuf.Values.Type.UNKNOWN):
+        elif ready == None or (isinstance(ready, function.protobuf.Values) and ready._isUnknown):
             ready = fnv1.Ready.READY_UNSPECIFIED
         else:
             ready = fnv1.Ready.READY_FALSE
@@ -415,7 +415,7 @@ def claim(self, claim):
         if bool(self):
             if claim:
                 self._result.target = fnv1.Target.TARGET_COMPOSITE_AND_CLAIM
-            elif claim == None or (isinstance(claim, function.protobuf.Values) and claim._type == function.protobuf.Values.Type.UNKNOWN):
+            elif claim == None or (isinstance(claim, function.protobuf.Values) and claim._isUnknown):
                 self._result.target = fnv1.Target.TARGET_UNSPECIFIED
             else:
                 self._result.target = fnv1.Target.TARGET_COMPOSITE
@@ -502,7 +502,7 @@ def status(self, status):
             condition.status = fnv1.Status.STATUS_CONDITION_TRUE
         elif status == None:
             condition.status = fnv1.Status.STATUS_CONDITION_UNKNOWN
-        elif isinstance(ready, function.protobuf.Values) and ready._type == function.protobuf.Values.Type.UNKNOWN:
+        elif isinstance(status, function.protobuf.Values) and status._isUnknown:
             condition.status = fnv1.Status.STATUS_CONDITION_UNSPECIFIED
         else:
             condition.status = fnv1.Status.STATUS_CONDITION_FALSE
@@ -549,7 +549,7 @@ def claim(self, claim):
         condition = self._find_condition(True)
         if claim:
             condition.target = fnv1.Target.TARGET_COMPOSITE_AND_CLAIM
-        elif claim == None or (isinstance(claim, function.protobuf.Values) and claim._type == function.protobuf.Values.Type.UNKNOWN):
+        elif claim == None or (isinstance(claim, function.protobuf.Values) and claim._isUnknown):
             condition.target = fnv1.Target.TARGET_UNSPECIFIED
         else:
             condition.target = fnv1.Target.TARGET_COMPOSITE

examples/inline/render.sh examples/single-purpose/render.shexamples/inline/render.sh renamed to examples/single-purpose/render.sh

@@ -21,15 +21,8 @@ def __init__(self):
         self.modules = {}
 
     async def RunFunction(
-        self, request: fnv1.RunFunctionRequest, context: grpc.aio.ServicerContext
+        self, request: fnv1.RunFunctionRequest, _: grpc.aio.ServicerContext
     ) -> fnv1.RunFunctionResponse:
-        try:
-            return await self.run(request, context)
-        except Exception as e:
-            self.logger.exception('Error during RunFuction')
-            raise
-
-    async def run(self, request, context):
         composite = request.observed.composite.resource
         logger = self.logger.bind(
             apiVersion=composite['apiVersion'],