Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 4 additions & 3 deletions cloudquery/sdk/scheduler/table_resolver.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,8 @@
from cloudquery.sdk.schema.table import Table
from cloudquery.sdk.schema import Resource
from typing import Any, Generator

from cloudquery.sdk.schema import Resource
from cloudquery.sdk.schema.table import Table


class TableResolver:
def __init__(self, table: Table, child_resolvers=[]) -> None:
Expand Down Expand Up @@ -31,7 +32,7 @@ def resolve_column(self, client, resource: Resource, column_name: str):
resource.set(column_name, resource.item[column_name])
else:
if hasattr(resource.item, column_name):
resource.set(column_name, resource.item[column_name])
resource.set(column_name, getattr(resource.item, column_name))

def post_resource_resolve(self, client, resource):
return
34 changes: 34 additions & 0 deletions tests/scheduler/table_resolver.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,34 @@
from dataclasses import dataclass

import pyarrow as pa

from cloudquery.sdk.scheduler import TableResolver
from cloudquery.sdk.schema import Table, Resource, Column


@dataclass
class TestItem:
test_column2: int = 1


def test_table_resolver_resolve_column():
test_table = Table(
name="test_table",
columns=[
Column(name="test_column", type=pa.int64()),
Column(name="test_column2", type=pa.int64()),
],
)
resource_dict = Resource(table=test_table, parent=None, item={"test_column": 1})
resource_obj = Resource(
table=test_table, parent=None, item=TestItem(test_column2=2)
)
test_resolver = TableResolver(table=test_table, child_resolvers=[])
test_resolver.resolve_column(
client=None, resource=resource_dict, column_name="test_column"
)
test_resolver.resolve_column(
client=None, resource=resource_obj, column_name="test_column2"
)
assert resource_dict.to_list_of_arr() == [[1], [None]]
assert resource_obj.to_list_of_arr() == [[None], [2]]