FilesExpand file tree

 main

/

fn.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

39 lines (30 loc) · 1.16 KB

 main

/

fn.py

Copy path

Top

File metadata and controls

• Code
• Blame

39 lines (30 loc) · 1.16 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

"""A Crossplane composition function."""

import grpc

from crossplane.function import logging, resource, response

from crossplane.function.proto.v1 import run_function_pb2 as fnv1

from crossplane.function.proto.v1 import run_function_pb2_grpc as grpcv1

class FunctionRunner(grpcv1.FunctionRunnerService):

"""A FunctionRunner handles gRPC RunFunctionRequests."""

def __init__(self):

"""Create a new FunctionRunner."""

self.log = logging.get_logger()

async def RunFunction(

self, req: fnv1.RunFunctionRequest, _: grpc.aio.ServicerContext

) -> fnv1.RunFunctionResponse:

"""Run the function."""

log = self.log.bind(tag=req.meta.tag)

log.info("Running function")

rsp = response.to(req)

version = req.input["version"]

region = req.observed.composite.resource["spec"]["region"]

resource.update(

rsp.desired.resources["bucket"],

{

"apiVersion": f"s3.aws.upbound.io/{version}",

"kind": "Bucket",

"spec": {

"forProvider": {"region": region},

},

},

)

return rsp