1
0
mirror of synced 2025-12-25 02:09:19 -05:00

format files (#8601)

This commit is contained in:
Marcos Marx
2021-12-07 16:42:04 -03:00
committed by GitHub
parent f00f10e66c
commit 161a1ee7b5
13 changed files with 19 additions and 14 deletions

View File

@@ -35,8 +35,8 @@ import org.slf4j.LoggerFactory;
* Snowflake Internal Staging consists of 4 main parts
*
* CREATE STAGE @TEMP_STAGE_NAME -- Creates a new named internal stage to use for loading data from
* files into Snowflake tables and unloading data from tables into files
* PUT file://local/<file-patterns> @TEMP_STAGE_NAME. --JDBC Driver will upload the files into stage
* files into Snowflake tables and unloading data from tables into files PUT
* file://local/<file-patterns> @TEMP_STAGE_NAME. --JDBC Driver will upload the files into stage
* COPY FROM @TEMP_STAGE_NAME -- Loads data from staged files to an existing table.
* DROP @TEMP_STAGE_NAME -- Drop temporary stage after sync
*/

View File

@@ -4,8 +4,6 @@
package io.airbyte.integrations.destination.snowflake;
import static io.airbyte.integrations.destination.snowflake.SnowflakeDestination.isInternalStaging;
import com.fasterxml.jackson.databind.JsonNode;
import com.google.common.base.Preconditions;
import io.airbyte.commons.io.IOs;

View File

@@ -196,11 +196,7 @@ class ReportsAmazonSPStream(Stream, ABC):
"""
Override to make http_method configurable per method call
"""
args = {
"method": http_method,
"url": urljoin(self.url_base, path),
"headers": headers, "params": params
}
args = {"method": http_method, "url": urljoin(self.url_base, path), "headers": headers, "params": params}
if http_method.upper() in BODY_REQUEST_METHODS:
if json and data:
raise RequestBodyException(

View File

@@ -1,6 +1,7 @@
#
# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
#
import json
import pytest

View File

@@ -1,6 +1,7 @@
#
# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
#
import datetime
import json
import os.path

View File

@@ -1,3 +1,7 @@
#
# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
#
import argparse
import concurrent.futures
import json

View File

@@ -1 +1 @@
{"last_update_timestamp": 1638751417.94276}
{ "last_update_timestamp": 1638751417.94276 }

View File

@@ -6,7 +6,6 @@
import sys
from airbyte_cdk.entrypoint import launch
from source_mailgun import SourceMailgun
if __name__ == "__main__":

View File

@@ -222,10 +222,10 @@
}
},
"timestamp": {
"type": "number"
"type": "number"
},
"user-variables": {
"type": ["null", "object"]
"type": ["null", "object"]
}
}
}

View File

@@ -1,6 +1,7 @@
#
# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
#
import datetime
import json
import logging

View File

@@ -1,3 +1,7 @@
#
# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
#
from base64 import b64encode
from unittest.mock import MagicMock

View File

@@ -1,6 +1,7 @@
#
# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
#
import time
import pytest as pytest

View File

@@ -1,13 +1,13 @@
#
# Copyright (c) 2021 Airbyte, Inc., all rights reserved.
#
import json
from unittest.mock import MagicMock
import pytest
import requests as requests
import responses
from source_mailgun.source import SourceMailgun
from . import TEST_CONFIG