import flow_api

def handler(system: flow_api.System, this: flow_api.Execution):
    postgres_server_version = this.connect(
        connector_type='SQLPS',
        host='my-postgres-server',
        fetchval='SELECT version()',
    ).get('output_value')['result']
    this.log(postgres_server_version=postgres_server_version)
    return this.success('all done')
