Skip to content

Commit ca7f03d

Browse files
committed
feat: Add Celery tasks overview, include commit hash in connector registration, and update gitignore for local development files.
1 parent 59f940b commit ca7f03d

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

connectors/tasks.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -96,8 +96,14 @@ def register_connectors(drd_cloud_host, drd_cloud_api_token, loaded_connections)
9696
connector_proto = credential_yaml_to_connector_proto(c, metadata)
9797
connectors.append(proto_to_dict(Connector(name=connector_proto.name, type=connector_proto.type)))
9898

99-
response = requests.post(f'{drd_cloud_host}/connectors/proxy/register',
99+
commit_hash = settings.VPC_AGENT_COMMIT_HASH
100+
url = f'{drd_cloud_host}/connectors/proxy/register?commit_hash={commit_hash}'
101+
logger.info(f'register_connectors:: Registering {len(connectors)} connectors with commit_hash: {commit_hash}')
102+
103+
response = requests.post(url,
100104
headers={'Authorization': f'Bearer {drd_cloud_api_token}'},
101105
json={'connectors': connectors})
102106
if response.status_code != 200:
103107
logger.error(f'Failed to register connectors with DRD Cloud: {response.json()}')
108+
else:
109+
logger.info(f'register_connectors:: Successfully registered connectors')

0 commit comments

Comments
 (0)