diff --git a/types/package.json b/types/package.json
index f5c5c5248739e..cc65acab7acb0 100644
--- a/types/package.json
+++ b/types/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/types",
-  "version": "0.3.3",
+  "version": "0.3.4",
   "description": "Pipedream TypeScript types",
   "keywords": [
     "pipedream",
diff --git a/types/src/index.ts b/types/src/index.ts
index 6ea9aa5cf0c4b..51ecafd1f74ad 100644
--- a/types/src/index.ts
+++ b/types/src/index.ts
@@ -1,3 +1,7 @@
+import {
+  Readable, Writable,
+} from "stream";
+
 /* eslint-disable @typescript-eslint/no-explicit-any */
 export type JSONValue =
   | string
@@ -69,7 +73,7 @@ export interface HTTPResponse {
   /**
    * Http Body
    */
-  body: string | Buffer | ReadableStream;
+  body: string | Buffer | Readable;
   /**
    * If true, issue the response when the promise returned is resolved, otherwise issue
    * the response at the end of the workflow execution
@@ -114,13 +118,13 @@ export interface IApi {
 
 export interface IFile {
   delete(): Promise<void>;
-  createReadStream(): Promise<ReadableStream>;
-  createWriteStream(contentType?: string, contentLength?: number): Promise<WritableStream>;
+  createReadStream(): Promise<Readable>;
+  createWriteStream(contentType?: string, contentLength?: number): Promise<Writable>;
   toEncodedString(encoding?: string, start?: number, end?: number): Promise<string>;
   toUrl(): Promise<string>;
   toFile(localFilePath: string): Promise<void>;
   toBuffer(): Promise<Buffer>;
-  fromReadableStream(readableStream: ReadableStream, contentType?: string, contentSize?: number): Promise<IFile>;
+  fromReadableStream(readableStream: Readable, contentType?: string, contentSize?: number): Promise<IFile>;
   fromFile(localFilePath: string, contentType?: string): Promise<IFile>;
   fromUrl(url: string, options?: any): Promise<IFile>;
   toJSON(): any;