Skip to content

Commit 74e663b

Browse files
committed
update template
1 parent 311bc9e commit 74e663b

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

src/snowflake/snowpark/data_source.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55
from typing import Any, Tuple, Iterator, Union, List
66

77
from snowflake.snowpark.types import StructType
8+
import snowflake
89

910

1011
class InputPartition:
@@ -43,3 +44,6 @@ def _partitions(self) -> List[InputPartition]:
4344
if self._internal_partitions is None:
4445
self._internal_partitions = self.reader(self.schema()).partitions()
4546
return self._internal_partitions
47+
48+
def udtf_ingestion(self) -> "snowflake.snowpark.DataFrame":
49+
pass

0 commit comments

Comments
 (0)