From a22d12f1dcbf71a597a6cabb48aeef500927fe47 Mon Sep 17 00:00:00 2001
From: Bassel <basselkanso82@gmail.com>
Date: Mon, 7 Nov 2022 11:10:05 +0200
Subject: [PATCH] refactoring schema export

---
 packages/core/data-transfer/lib/engine/index.ts  | 2 +-
 packages/core/data-transfer/types/providers.d.ts | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/packages/core/data-transfer/lib/engine/index.ts b/packages/core/data-transfer/lib/engine/index.ts
index faa306b1a8..26cdd62d90 100644
--- a/packages/core/data-transfer/lib/engine/index.ts
+++ b/packages/core/data-transfer/lib/engine/index.ts
@@ -132,7 +132,7 @@ class TransferEngine implements ITransferEngine {
   async transferSchemas(): Promise<void> {
     const inStream = await this.sourceProvider.streamSchemas?.();
     const outStream = await this.destinationProvider.getSchemasStream?.();
-    console.log(inStream);
+
     if (!inStream || !outStream) {
       throw new Error('Unable to transfer schemas, one of the streams is missing');
     }
diff --git a/packages/core/data-transfer/types/providers.d.ts b/packages/core/data-transfer/types/providers.d.ts
index b7b0813555..e9c4e1d2d4 100644
--- a/packages/core/data-transfer/types/providers.d.ts
+++ b/packages/core/data-transfer/types/providers.d.ts
@@ -20,7 +20,7 @@ export interface ISourceProvider extends IProvider {
   streamMedia?(): NodeJS.ReadableStream | Promise<NodeJS.ReadableStream>;
   streamConfiguration?(): NodeJS.ReadableStream | Promise<NodeJS.ReadableStream>;
   getSchemas?(): any;
-  streamSchemas?(): NodeJS.ReadableStream;
+  streamSchemas?(): NodeJS.ReadableStream | Promise<NodeJS.ReadableStream>;
 }
 
 export interface IDestinationProvider extends IProvider {