Hello everyone! I built a simple ETL and it is working perfectly. When I run the agent in the cloud I get an error saying "cannot pickle psycopg2", any clues?

Hi @Tomás Emilio Silva Ebensperger - it sounds like you've baked in part of the

psycopg2

module as part of your flow's metadata, perhaps by referencing it outside of a task block. Since a flow's metadata (right now) needs to be pickleable so that it can be sent to the API, you'll need to make sure you're not inadvertently introducing non-pickleable objects.

makes sense, thank you

Ah, good question -> I personally use OOP by default when writing flows for similar reasons; for instance you can write a task following normal class inheritance models like this:

class CheckInstance(Task):
    def list_instances(self, service, project, zone):
        result = service.instances().list(project=project, zone=zone).execute()
        return result["items"] if "items" in result else None

    def run(self, credentials, instance, project, zone):
        service = googleapiclient.discovery.build(
            "compute", "v1", credentials=credentials
        )

        instances = self.list_instances(service, project, zone)

        super(CheckInstance, self).run()
        return any(i["name"] == instance for i in instances)

thanks!