4
4
import logging
5
5
from psycopg2 .extras import DictCursor
6
6
import zulip
7
+ from datetime import datetime
7
8
8
9
logging .basicConfig (level = logging .INFO , format = '%(asctime)s - %(levelname)s - %(message)s' )
9
10
@@ -117,6 +118,7 @@ def check_outdated_docs(conn, squad_name, stream_name, topic_name):
117
118
118
119
119
120
def send_zulip_notification (row , api_key , stream_name , topic_name ):
121
+ current_date = datetime .now ().strftime ("%Y-%m-%d" )
120
122
client = zulip .
Client (
email = "[email protected] " ,
api_key = api_key ,
site = "https://zulip.tsi-vc.otc-service.com" )
121
123
if row ["type" ] == "doc" :
122
124
squad_name = row [3 ]
@@ -140,22 +142,22 @@ def send_zulip_notification(row, api_key, stream_name, topic_name):
140
142
else :
141
143
return
142
144
143
- message += f"\n \n **Squad name:** { squad_name } \n **Service name:** { service_name } \n **Zone:** { row [- 2 ]} \n \n **Commit" \
145
+ message += f"\n \n **Squad name:** { squad_name } \n **Service name:** { service_name } \n **Zone:** { row [- 2 ]} \n **Date:** { current_date } \n \n **Commit" \
144
146
f" URL:** { commit_url } \n **Dashboard URL:** https://dashboard.tsi-dev.otc-service.com/d/c67f0f4b-b31c-" \
145
147
f"4433-b530-a18896470d49/last-docs-commit?orgId=1\n \n ---------------------------------------------------------"
146
148
elif row ["type" ] == "issue" :
147
149
squad_name = row [3 ]
148
150
service_name = row [2 ]
149
151
issue_url = row [5 ]
150
152
message = f":point_right: **Unattended Issues Alert** :point_left:\n \n You have an issue which has no assignees for more than 7 days\n \n " \
151
- f"**Squad name:** { squad_name } \n **Service name:** { service_name } \n **Zone:** { row [- 2 ]} \n \n **Issue URL:" \
153
+ f"**Squad name:** { squad_name } \n **Service name:** { service_name } \n **Zone:** { row [- 2 ]} \n **Date:** { current_date } \n \n **Issue URL:" \
152
154
f"** { issue_url } \n **Dashboard URL:** https://dashboard.tsi-dev.otc-service.com/d/I-YJAuBVk/open-issues" \
153
155
f"-dashboard?orgId=1&var-squad_issues=All&var-env_issues=All&var-sort_duration=DESC&var-zone=open_issues\n \n ---------------------------------------------------------"
154
156
elif row ["type" ] == "orphan" :
155
157
squad_name = row [3 ]
156
158
service_name = row [2 ]
157
159
orphan_url = row [4 ]
158
- message = f":boom: **Orphaned PRs Alert** :boom:\n \n You have orphaned PR here!\n \n **Squad name:** { squad_name } \n **Service name:** { service_name } \n **Zone:** { row [- 2 ]} \n \n " \
160
+ message = f":boom: **Orphaned PRs Alert** :boom:\n \n You have orphaned PR here!\n \n **Squad name:** { squad_name } \n **Service name:** { service_name } \n **Zone:** { row [- 2 ]} \n **Date:** { current_date } \n \n " \
159
161
f"**Orphan URL:** { orphan_url } \n **Dashboard URL:** https://dashboard.tsi-dev.otc-service.com/d/4vLGLDB" \
160
162
f"4z/open-prs-dashboard?orgId=1\n \n ---------------------------------------------------------"
161
163
result = client .send_message ({
0 commit comments