Skip to content

Commit

Permalink
Merge pull request #111 from rudderlabs/fix-stripeConflicts
Browse files Browse the repository at this point in the history
fix: resolves conflicts from upstream merge
  • Loading branch information
a-rampalli committed May 12, 2023
2 parents 78e97f3 + ff33d57 commit 46c5330
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 76 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -61,15 +61,7 @@ class Config:

end_date: Optional[datetime] = Field(
title="End Date",
<<<<<<< HEAD
description="The field is the date until which to pull data. If not specified, we will use the latest data available.",
=======
description=(
"The date until which you'd like to replicate data for this stream, in the format YYYY-MM-DDT00:00:00Z. "
"All data generated between the start date and this end date will be replicated. "
"Not setting this option will result in always syncing the latest data."
),
>>>>>>> upstream/master
pattern=DATE_TIME_PATTERN,
examples=["2017-01-26T00:00:00Z"],
)
Expand Down Expand Up @@ -100,16 +92,7 @@ def schema_extra(schema: Dict[str, Any], model: Type["ConnectorConfig"]) -> None

account_id: str = Field(
title="Account ID",
<<<<<<< HEAD
order=1,
=======
order=0,
description=(
"The Facebook Ad account ID to use when pulling data from the Facebook Marketing API."
" Open your Meta Ads Manager. The Ad account ID number is in the account dropdown menu or in your browser's address bar. "
'See the <a href="https://www.facebook.com/business/help/1492627900875762">docs</a> for more information.'
),
>>>>>>> upstream/master
examples=["111111111111111"],
)

Expand All @@ -122,45 +105,17 @@ def schema_extra(schema: Dict[str, Any], model: Type["ConnectorConfig"]) -> None

end_date: Optional[datetime] = Field(
title="End Date",
<<<<<<< HEAD
description="The field is the date until which to pull data. If not specified, we will use the latest data available.",
order=3,
=======
order=2,
description=(
"The date until which you'd like to replicate data for all incremental streams, in the format YYYY-MM-DDT00:00:00Z."
" All data generated between the start date and this end date will be replicated. "
"Not setting this option will result in always syncing the latest data."
),
>>>>>>> upstream/master
pattern=EMPTY_PATTERN + "|" + DATE_TIME_PATTERN,
examples=["2017-01-26T00:00:00Z"],
default_factory=lambda: datetime.now(tz=timezone.utc),
)

<<<<<<< HEAD
=======
access_token: str = Field(
title="Access Token",
order=3,
description=(
"The value of the generated access token. "
'From your App’s Dashboard, click on "Marketing API" then "Tools". '
'Select permissions <b>ads_management, ads_read, read_insights, business_management</b>. Then click on "Get token". '
'See the <a href="https://docs.airbyte.com/integrations/sources/facebook-marketing">docs</a> for more information.'
),
airbyte_secret=True,
)

>>>>>>> upstream/master
include_deleted: bool = Field(
title="Include Deleted Campaigns, Ads, and AdSets",
order=4,
default=False,
<<<<<<< HEAD
=======
description="Set to active if you want to include data from deleted Campaigns, Ads, and AdSets.",
>>>>>>> upstream/master
)

fetch_thumbnail_images: bool = Field(
Expand All @@ -183,27 +138,11 @@ def schema_extra(schema: Dict[str, Any], model: Type["ConnectorConfig"]) -> None
title="Page Size of Requests",
order=7,
default=100,
<<<<<<< HEAD
=======
description=(
"Page size used when sending requests to Facebook API to specify number of records per page when response has pagination. "
"Most users do not need to set this field unless they specifically need to tune the connector to address specific issues or use cases."
),
>>>>>>> upstream/master
)

insights_lookback_window: Optional[PositiveInt] = Field(
title="Insights Lookback Window",
order=8,
<<<<<<< HEAD
=======
description=(
"The attribution window. Facebook freezes insight data 28 days after it was generated, "
"which means that all data from the past 28 days may have changed since we last emitted it, "
"so you can retrieve refreshed insights from the past by setting this parameter. "
"If you set a custom lookback window value in Facebook account, please provide the same value here."
),
>>>>>>> upstream/master
maximum=28,
mininum=1,
default=28,
Expand All @@ -212,13 +151,6 @@ def schema_extra(schema: Dict[str, Any], model: Type["ConnectorConfig"]) -> None
max_batch_size: Optional[PositiveInt] = Field(
title="Maximum size of Batched Requests",
order=9,
<<<<<<< HEAD
=======
description=(
"Maximum batch size used when sending batch requests to Facebook API. "
"Most users do not need to set this field unless they specifically need to tune the connector to address specific issues or use cases."
),
>>>>>>> upstream/master
default=50,
)

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -201,7 +201,6 @@
"UriEvent",
]

<<<<<<< HEAD
RESOURCE_PRIMARY_KEY_MAP = {
"PlatformEventUsageMetric": None, # PlatformEventUsageMetric does not have a primary key
"FormulaFunctionAllowedType": "DurableId", # https://developer.salesforce.com/docs/atlas.en-us.object_reference.meta/object_reference/sforce_api_objects_formulafunctionallowedtype.htm
Expand All @@ -211,9 +210,7 @@
"Publisher": "DurableId", # https://developer.salesforce.com/docs/atlas.en-us.api_tooling.meta/api_tooling/tooling_api_objects_publisher.htm
"ApexPageInfo": "DurableId" # https://developer.salesforce.com/docs/atlas.en-us.api_tooling.meta/api_tooling/tooling_api_objects_apexpageinfo.htm
}
=======
UNSUPPORTED_STREAMS = ["ActivityMetric", "ActivityMetricRollup"]
>>>>>>> upstream/master


class Salesforce:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,12 +12,7 @@
from airbyte_cdk.models import SyncMode
from airbyte_cdk.sources.streams.availability_strategy import AvailabilityStrategy
from airbyte_cdk.sources.streams.http import HttpStream
<<<<<<< HEAD
from airbyte_cdk.sources.streams import IncrementalMixin
from datetime import datetime
=======
from source_stripe.availability_strategy import StripeSubStreamAvailabilityStrategy
>>>>>>> upstream/master

STRIPE_ERROR_CODES: List = [
# stream requires additional permissions
Expand Down

0 comments on commit 46c5330

Please sign in to comment.