Configure logging after pip install is run

Author: Patrick J. McNerthney

crossplane/pythonic/composite.py

@@ -41,7 +41,7 @@ def __init__(self, request, logger):
         self.kind = self.observed.kind
         self.metadata = self.observed.metadata
         self.spec = self.observed.spec
-        self.status = Status(self.observed.status, self.desired.status)
+        self.status = self.desired.status
         self.conditions = Conditions(observed, self.response)
         self.connection = Connection(observed, desired)
         self.events = Events(self.response)
@@ -217,10 +217,9 @@ def kind(self, kind):
 
     @property
     def externalName(self):
-        name = self.metadata.annotations['crossplane.io/external-name']
-        if not name:
-            name = self.observed.metadata.annotations['crossplane.io/external-name']
-        return name
+        if 'crossplane.io/external-name' in self.metadata.annotations:
+            return self.metadata.annotations['crossplane.io/external-name']
+        return self.observed.metadata.annotations['crossplane.io/external-name']
 
     @externalName.setter
     def externalName(self, name):
@@ -409,27 +408,6 @@ def __bool__(self):
         return bool(self.observed)
 
 
-class Status:
-    def __init__(self, observed, desired):
-        self.__dict__['_observed'] = observed
-        self.__dict__['_desired'] = desired
-
-    def __getattr__(self, key):
-        return self[key]
-
-    def __getitem__(self, key):
-        value = self._desired[key]
-        if value is None:
-            value = self._observed[key]
-        return value
-
-    def __setattr__(self, key, value):
-        self[key] = value
-
-    def __setitem__(self, key, value):
-        self._desired[key] = value
-
-
 class Conditions:
     def __init__(self, observed, response=None):
         self._observed = observed

crossplane/pythonic/main.py

@@ -102,20 +102,20 @@ async def main(self):
             print('Either --tls-certs-dir or --insecure must be specified', file=sys.stderr)
             sys.exit(1)
 
-        self.configure_logging(args)
-        # enables read only volumes or mismatched uid volumes
-        sys.dont_write_bytecode = True
-        await self.run(args)
-
-    # Allow for independent running of function-pythonic
-    async def run(self, args):
         if args.pip_install:
             import pip._internal.cli.main
             pip._internal.cli.main.main(['install', '--user', *shlex.split(args.pip_install)])
 
         for path in reversed(args.python_path):
             sys.path.insert(0, str(pathlib.Path(path).expanduser().resolve()))
 
+        self.configure_logging(args)
+        # enables read only volumes or mismatched uid volumes
+        sys.dont_write_bytecode = True
+        await self.run(args)
+
+    # Allow for independent running of function-pythonic
+    async def run(self, args):
         if args.allow_oversize_protos:
             from google.protobuf.internal import api_implementation
             if api_implementation._c_module:
@@ -166,7 +166,7 @@ def configure_logging(self, args):
         handler = logging.StreamHandler()
         handler.setFormatter(formatter)
         logger = logging.getLogger()
-        logger.addHandler(handler)
+        logger.handlers = [handler]
         logger.setLevel(logging.DEBUG if args.debug else logging.INFO)
 
 

examples/import-existing-vpc/composition.yaml

@@ -48,7 +48,7 @@ spec:
                   vpc.externalName = vpcs[0]['VpcId']
                 else:
                   self.events.fatal('MultipleResources', f"More than one vpc found for: {self.metadata.name}")
-            self.status.vpcId = vpc.status.atProvider.vpcId
+            self.status.vpcId = vpc.status.atProvider.id
             return vpc
 
           def aws_client(self, service):

examples/single-purpose/xr.yaml

@@ -6,4 +6,5 @@ spec:
   composite: |
     class Composite(BaseComposite):
       def compose(self):
+        self.logger.info('Debug World!')
         self.status.composite = 'Hello, World!'

scripts/setup-local.sh

@@ -193,15 +193,16 @@ spec:
 EOF
 
 #  package: ghcr.io/fortra/function-pythonic:v0.0.0-20250819201108-49cfb066579f
-#  package: ghcr.io/iciclespider/function-pythonic:v0.0.0-20251007211722-f132f8e3d368
+#  package: ghcr.io/iciclespider/function-pythonic:v0.0.0-20251014192239-4779a870d7fd
+#  package: ghcr.io/fortra/function-pythonic:v0.1.1
 
 kubectl apply -f - <<EOF
 apiVersion: pkg.crossplane.io/v1
 kind: Function
 metadata:
   name: function-pythonic
 spec:
-  package: ghcr.io/fortra/function-pythonic:v0.1.1
+  package: ghcr.io/iciclespider/function-pythonic:v0.0.0-20251014192239-4779a870d7fd
   runtimeConfigRef:
     apiVersion: pkg.crossplane.io/v1beta1
     kind: DeploymentRuntimeConfig