Skip to content

Commit 9975ec4

Browse files
author
Jakob Külzer
committed
fixed broken follow
1 parent b4ac168 commit 9975ec4

File tree

2 files changed

+14
-3
lines changed

2 files changed

+14
-3
lines changed

azkaban/client.go

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -232,5 +232,16 @@ func (c *Client) request(method string, path string, params map[string]string) (
232232
q.Add(k, v)
233233
}
234234
req.URL.RawQuery = q.Encode()
235-
return c.http.Do(req)
235+
resp, err := c.http.Do(req)
236+
if c.DumpResponses {
237+
b, err := httputil.DumpResponse(resp, true)
238+
if err != nil {
239+
return nil, err
240+
}
241+
242+
fmt.Printf("%s %s: \n", method, resp.Request.URL.String())
243+
fmt.Printf("%s\n", b)
244+
}
245+
246+
return resp, err
236247
}

main.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -161,7 +161,7 @@ func main() {
161161
for {
162162
select {
163163
case <-ticker.C:
164-
offset, err = client.FetchLogsUntilEnd(*logsExecID, *logsJobID, offset, os.Stdout)
164+
offset, err = client.FetchLogsUntilEnd(execID, projectID, offset, os.Stdout)
165165
if err != nil {
166166
panic(err)
167167
}
@@ -186,7 +186,7 @@ func getClient() *azkaban.Client {
186186
panic(err)
187187
}
188188

189-
// client.DumpResponses = *dumpResponses
189+
client.DumpResponses = *dumpResponses
190190

191191
return client
192192
}

0 commit comments

Comments
 (0)