File tree Expand file tree Collapse file tree 2 files changed +4
-0
lines changed Expand file tree Collapse file tree 2 files changed +4
-0
lines changed Original file line number Diff line number Diff line change 1818
1919from snowflake .connector import ProgrammingError
2020from snowflake .connector .options import pandas
21+ from snowflake .connector .telemetry import TelemetryData , TelemetryField
2122
2223if TYPE_CHECKING : # pragma: no cover
2324 from .connection import SnowflakeConnection
@@ -279,6 +280,7 @@ def write_pandas(
279280 )
280281 logger .debug (f"copying into with '{ copy_into_sql } '" )
281282 copy_results = cursor .execute (copy_into_sql , _is_internal = True ).fetchall ()
283+ cursor ._log_telemetry_job_data (TelemetryField .PANDAS_WRITE , TelemetryData .TRUE )
282284 cursor .close ()
283285 return (
284286 all (e [1 ] == "LOADED" for e in copy_results ),
Original file line number Diff line number Diff line change @@ -37,6 +37,8 @@ class TelemetryField(Enum):
3737 # fetch_arrow_* usage
3838 ARROW_FETCH_ALL = "client_fetch_arrow_all"
3939 ARROW_FETCH_BATCHES = "client_fetch_arrow_batches"
40+ # write_pandas usage
41+ PANDAS_WRITE = "client_write_pandas"
4042 # imported packages along with client
4143 IMPORTED_PACKAGES = "client_imported_packages"
4244 # Keys for telemetry data sent through either in-band or out-of-band telemetry
You can’t perform that action at this time.
0 commit comments