1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
--- a/job.go
+++ b/job.go
@@ -6,12 +6,8 @@
"net/url"
"os"
"regexp"
- "strconv"
"strings"
"time"
- "crypto/rsa"
- "crypto/x509"
- "encoding/pem"
"github.com/cenkalti/backoff"
"github.com/go-kit/log"
@@ -23,7 +19,6 @@
_ "github.com/microsoft/go-mssqldb" // register the MS-SQL driver
_ "github.com/microsoft/go-mssqldb/integratedauth/krb5" // Register integrated auth for MS-SQL
"github.com/prometheus/client_golang/prometheus"
- "github.com/snowflakedb/gosnowflake"
sqladmin "google.golang.org/api/sqladmin/v1beta4"
"github.com/aws/aws-sdk-go/aws/session"
@@ -394,6 +389,7 @@
}
}
*/
+ /*
if newConn.driver == "snowflake" {
u, err := url.Parse(conn)
if err != nil {
@@ -476,7 +472,7 @@
j.conns = append(j.conns, newConn)
continue
}
-
+ */
j.conns = append(j.conns, newConn)
}
}
--- a/config.go
+++ b/config.go
@@ -15,7 +15,6 @@
"github.com/prometheus/client_golang/prometheus"
"github.com/prometheus/client_golang/prometheus/promauto"
"github.com/robfig/cron/v3"
- "github.com/snowflakedb/gosnowflake"
"gopkg.in/yaml.v2"
)
@@ -165,7 +164,7 @@
user string
tokenExpirationTime time.Time
iteratorValues []string
- snowflakeConfig *gosnowflake.Config
+// snowflakeConfig *gosnowflake.Config
snowflakeDSN string
}
|
