We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent bed6c40 commit 145802cCopy full SHA for 145802c
lib/actions/write.js
@@ -21,8 +21,6 @@ function init() {
21
22
signedUrl = yield client.resources.storage.createSignedUrl();
23
24
- console.log(signedUrl);
25
-
26
let putUrl = signedUrl.put_url;
27
console.log('CSV file to be uploaded file to uri=%s', putUrl);
28
@@ -51,16 +49,15 @@ function processAction(msg) {
51
49
"content-type": "text/csv",
52
50
url: signedUrl.get_url
53
};
54
- console.log('%j', messageToEmit);
55
signedUrl = null;
56
rowCount = 0;
57
58
- console.log('Emitting message');
+ console.log('Emitting message %j', messageToEmit);
59
self.emit('data', messageToEmit);
60
61
yield init();
62
});
63
- }, 5000);
+ }, 10000);
64
65
console.log('Writing to stream', msg.body);
66
0 commit comments