Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.

Prefect Community

I'm confused about how to use @resource_manager effectively. I am using it to create an RDS instance in AWS. I can create it fine in setup and destroy it in cleanup but I don't understand how to get the endpoint out of it. It seems to wrap it in a ResourceManager so I can't access any attributes of my class from the flow. How can I use the client as instantiated here `with OracleRDS() as client` ?

HI <@U01PW2TAH2S>! Did you try passing the `client` into Tasks inside the `with OracleRDS() as client` ?

I did and it seems to be passed as a string so I can't access any attributes of the class

`Unexpected error: AttributeError("'str' object has no attribute 'connection_string'")`

```with OracleRDS() as client:
    result = SomeImportTask()(input_url, xer['job_queue'], xer['job_definition'], client)```
and
```class SomeImportTask(BatchExecuteTask):
    def run(self, input_url: str, job_queue_arn: str, job_definition_arn: str, rds) -&gt; str:
        super().run('SomeImportTask', job_queue_arn, job_definition_arn,
                    {'input_url': input_url, 'connection_string': rds.connection_string})
        <http://self.logger.info|self.logger.info>(f'Finished importing {input_url}')
        return rds.connection_string```


```@resource_manager
class OracleRDS:
    def __init__(self, username_arn, password_arn, rds_integration_role, rds_option_group, subnet_group, port, sg) -&gt; None:
        self._rds = boto3.client('rds')
        self._username_arn = username_arn
        self._password_arn = password_arn
        self._rds_integration_role = rds_integration_role
        self._rds_option_group = rds_option_group
        self._subnet_group = subnet_group
        self._port = port
        self._sg = sg
        self._connection_string = None

    @property
    def connection_string(self):
        return self._connection_string

    def setup(self):...```


currently I am returning an id needed to destroy the instance in cleanup

Oh could you tell me what it was? Been looking at it myself. Would like to know.

if you return self from setup then you have access to the object