diff --git a/airbyte-integrations/connectors/source-brightspace/metadata.yaml b/airbyte-integrations/connectors/source-brightspace/metadata.yaml index d3f759803a14..8519e4d8b7f7 100644 --- a/airbyte-integrations/connectors/source-brightspace/metadata.yaml +++ b/airbyte-integrations/connectors/source-brightspace/metadata.yaml @@ -15,7 +15,7 @@ data: connectorSubtype: api connectorType: source definitionId: 694710ca-8933-4661-8db9-c38cb60411b0 - dockerImageTag: 0.2.5 + dockerImageTag: 0.2.6 dockerRepository: datapipes-airbyte/source-brightspace githubIssueLabel: source-brightspace icon: brightspace.svg diff --git a/airbyte-integrations/connectors/source-brightspace/source_brightspace/spec.yaml b/airbyte-integrations/connectors/source-brightspace/source_brightspace/spec.yaml index c92c8b07f403..28cac399d6c5 100644 --- a/airbyte-integrations/connectors/source-brightspace/source_brightspace/spec.yaml +++ b/airbyte-integrations/connectors/source-brightspace/source_brightspace/spec.yaml @@ -278,7 +278,6 @@ connectionSpecification: required: - org_unit_id - start_date - - roles properties: dataset_type: type: string @@ -314,7 +313,6 @@ connectionSpecification: required: - org_unit_id - start_date - - roles properties: dataset_type: type: string @@ -379,7 +377,6 @@ connectionSpecification: required: - org_unit_id - start_date - - roles properties: dataset_type: type: string diff --git a/airbyte-integrations/connectors/source-brightspace/source_brightspace/streams.py b/airbyte-integrations/connectors/source-brightspace/source_brightspace/streams.py index 53342d4344e1..29396d2dd2fa 100644 --- a/airbyte-integrations/connectors/source-brightspace/source_brightspace/streams.py +++ b/airbyte-integrations/connectors/source-brightspace/source_brightspace/streams.py @@ -574,13 +574,15 @@ def create_export_job(self) -> BSExportJob: { "name": "endDate", "value": self.end_date - }, - { - "name": "roles", - "value": ",".join(map(str, self.roles)) } + ] } + if self.roles is not None: + payload['Filters'].append({ + "name": "roles", + "value": ",".join(map(str, self.roles)) + }) return self.bs_api.create_export_job(payload=payload) @@ -655,13 +657,15 @@ def create_export_job(self) -> BSExportJob: { "name": "endDate", "value": self.end_date - }, - { - "name": "roles", - "value": ",".join(map(str, self.roles)) } ] } + if self.roles is not None: + payload['Filters'].append({ + "name": "roles", + "value": ",".join(map(str, self.roles)) + }) + return self.bs_api.create_export_job(payload=payload)