Skip to content

Commit 217644b

Browse files
remove bounds from query payload (#80)
* remove bounds from query * bump version
1 parent 46f8588 commit 217644b

File tree

7 files changed

+44
-3
lines changed

7 files changed

+44
-3
lines changed

cli-e2e-test/rel/city.rel

+8
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,11 @@
1+
module import_config:city_data
2+
def schema = {
3+
:city, "string"
4+
}
5+
6+
bound syntax:header
7+
end
8+
19
module city_data
210
def CITY_NAME[idx, row] = source_catalog:city_data[idx, :city, row]
311
end

cli-e2e-test/rel/device.rel

+9
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,12 @@
1+
module import_config:device_data
2+
def schema = {
3+
:device, "string" ;
4+
:IMEI, "int"
5+
}
6+
7+
bound syntax:header
8+
end
9+
110
module device_data
211
def DEVICE_NAME[idx, row] = source_catalog:device_data[idx, :device, row]
312
end

cli-e2e-test/rel/device_seen.rel

+9
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,12 @@
1+
module import_config:device_seen_snapshot
2+
def schema = {
3+
:device, "string" ;
4+
:last_seen, "date"
5+
}
6+
7+
bound syntax:header
8+
end
9+
110
module device_seen_snapshot
211
def DEVICE_NAME[idx, row] = source_catalog:device_seen_snapshot[idx, :device, row]
312
def LAST_SEEN[idx, row] = source_catalog:device_seen_snapshot[idx, :last_seen, row]

cli-e2e-test/rel/product.rel

+8
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,11 @@
1+
module import_config:product_data
2+
def schema = {
3+
:product, "string"
4+
}
5+
6+
bound syntax:header
7+
end
8+
19
module product_data
210
def PRODUCT_NAME[idx, row] = source_catalog:product_data[idx, :product, row]
311
end

cli-e2e-test/rel/user.rel

+9
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,12 @@
1+
module import_config:user_data
2+
def schema = {
3+
:user_id, "int" ;
4+
:user_name, "string"
5+
}
6+
7+
bound syntax:header
8+
end
9+
110
module user_data
211
def USER_NAME[idx, row] = source_catalog:user_data[idx, :user_name, row]
312
end

workflow/__init__.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -12,5 +12,5 @@
1212
# See the License for the specific language governing permissions and
1313
# limitations under the License.
1414

15-
__version_info__ = (0, 0, 45)
15+
__version_info__ = (0, 0, 46)
1616
__version__ = ".".join(map(str, __version_info__))

workflow/query.py

-2
Original file line numberDiff line numberDiff line change
@@ -343,8 +343,6 @@ def _multi_part_load_config_query(rel_name: str, file_type: FileType, config_int
343343
f"def syntax:header = {IMPORT_CONFIG_REL}:{rel_name}:syntax:header"
344344

345345
return f"""
346-
bound {IMPORT_CONFIG_REL}:{rel_name}:schema
347-
bound {IMPORT_CONFIG_REL}:{rel_name}:syntax:header
348346
module {_config_rel_name(rel_name)}[i in part_indexes:{rel_name}]
349347
{schema}
350348
{config_integration}

0 commit comments

Comments
 (0)