Skip to content

Commit 7befa93

Browse files
authored
Stop publishing java connectors on merge to master (#28344)
* process language after modified flag * modify some connectors * empty commit * another bump * modified connectors are already filtered * change some connectors * change some connectors again * revert to master version * nit * filter for python/lowcode connectors
1 parent 1c87175 commit 7befa93

File tree

2 files changed

+6
-9
lines changed

2 files changed

+6
-9
lines changed

.github/workflows/publish_connectors.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ jobs:
3939
metadata_service_gcs_credentials: ${{ secrets.METADATA_SERVICE_PROD_GCS_CREDENTIALS }}
4040
slack_webhook_url: ${{ secrets.PUBLISH_ON_MERGE_SLACK_WEBHOOK }}
4141
spec_cache_gcs_credentials: ${{ secrets.SPEC_CACHE_SERVICE_ACCOUNT_KEY_PUBLISH }}
42-
subcommand: "connectors --concurrency=1 --execute-timeout=3600 --modified publish --main-release"
42+
subcommand: "connectors --concurrency=1 --execute-timeout=3600 --modified --language=python --language=low-code publish --main-release"
4343

4444
- name: Publish connectors [manual]
4545
id: publish-connectors

tools/ci_connector_ops/ci_connector_ops/pipelines/commands/groups/connectors.py

Lines changed: 5 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -103,6 +103,8 @@ def connectors(
103103
# and attach modified files to them
104104
selected_connectors_and_files = {connector: modified_connectors_and_files.get(connector, []) for connector in all_connectors}
105105

106+
if modified:
107+
selected_connectors_and_files = modified_connectors_and_files
106108
if names:
107109
selected_connectors_and_files = {
108110
connector: selected_connectors_and_files[connector]
@@ -121,8 +123,6 @@ def connectors(
121123
for connector in selected_connectors_and_files
122124
if connector.release_stage in release_stages
123125
}
124-
if modified:
125-
selected_connectors_and_files = modified_connectors_and_files
126126

127127
ctx.obj["selected_connectors_and_files"] = selected_connectors_and_files
128128
ctx.obj["selected_connectors_names"] = [c.technical_name for c in selected_connectors_and_files.keys()]
@@ -312,12 +312,9 @@ def publish(
312312
"Publishing from a local environment is not recommend and requires to be logged in Airbyte's DockerHub registry, do you want to continue?",
313313
abort=True,
314314
)
315-
if ctx.obj["modified"]:
316-
selected_connectors_and_files = get_modified_connectors(get_modified_metadata_files(ctx.obj["modified_files"]))
317-
selected_connectors_names = [connector.technical_name for connector in selected_connectors_and_files.keys()]
318-
else:
319-
selected_connectors_and_files = ctx.obj["selected_connectors_and_files"]
320-
selected_connectors_names = ctx.obj["selected_connectors_names"]
315+
316+
selected_connectors_and_files = ctx.obj["selected_connectors_and_files"]
317+
selected_connectors_names = ctx.obj["selected_connectors_names"]
321318

322319
main_logger.info(f"Will publish the following connectors: {', '.join(selected_connectors_names)}")
323320
publish_connector_contexts = reorder_contexts(

0 commit comments

Comments
 (0)