Skip to content

Commit 9843b68

Browse files
committed
added user-defined-functions.csv
1 parent 55c1776 commit 9843b68

File tree

1 file changed

+13
-11
lines changed

1 file changed

+13
-11
lines changed

dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/snowflake/SnowflakeLogsConnector.java

Lines changed: 13 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -300,17 +300,19 @@ public final void addTasksTo(
300300
out.add(new FormatTask(FORMAT_NAME));
301301
out.add(SnowflakeYamlSummaryTask.create(FORMAT_NAME, arguments));
302302

303-
String userDefinedFunctions =
304-
"SELECT FUNCTION_SCHEMA, FUNCTION_NAME, FUNCTION_LANGUAGE, ARGUMENT_SIGNATURE, "
305-
+ "FUNCTION_OWNER, COMMENT, VOLATILITY, RUNTIME_VERSION, LAST_ALTERED, "
306-
+ "PACKAGES, IMPORTS, IS_AGGREGATE, IS_DATA_METRIC, IS_MEMOIZABLE "
307-
+ "FROM SNOWFLAKE.ACCOUNT_USAGE.FUNCTIONS "
308-
+ "WHERE FUNCTION_SCHEMA != 'INFORMATION_SCHEMA' "
309-
+ "AND DELETED IS NULL";
310-
out.add(
311-
new JdbcSelectTask(
312-
"user-defined-functions.csv", userDefinedFunctions, TaskCategory.OPTIONAL)
313-
.withHeaderClass(FunctionsHeader.class));
303+
if (arguments.isAssessment()) {
304+
String userDefinedFunctions =
305+
"SELECT FUNCTION_SCHEMA, FUNCTION_NAME, FUNCTION_LANGUAGE, ARGUMENT_SIGNATURE, "
306+
+ "FUNCTION_OWNER, COMMENT, VOLATILITY, RUNTIME_VERSION, LAST_ALTERED, "
307+
+ "PACKAGES, IMPORTS, IS_AGGREGATE, IS_DATA_METRIC, IS_MEMOIZABLE "
308+
+ "FROM SNOWFLAKE.ACCOUNT_USAGE.FUNCTIONS "
309+
+ "WHERE FUNCTION_SCHEMA != 'INFORMATION_SCHEMA' "
310+
+ "AND DELETED IS NULL";
311+
out.add(
312+
new JdbcSelectTask(
313+
"user-defined-functions.csv", userDefinedFunctions, TaskCategory.OPTIONAL)
314+
.withHeaderClass(FunctionsHeader.class));
315+
}
314316

315317
// (24 * 7) -> 7 trailing days == 168 hours
316318
// Actually, on Snowflake, 7 days ago starts at midnight in an unadvertised time zone. What the

0 commit comments

Comments
 (0)