Update reply comment

scripts/release_issue_status/main.py

@@ -17,7 +17,9 @@
 _NULL = ' '
 _FILE_OUT = 'release_issue_status.csv'
 _FILE_OUT_PYTHON = 'release_python_status.md'
-_PYTHON_SDK_ADMINISTRATORS = {'msyyc', 'RAY-316', 'BigCat20196'}
+_PYTHON_SDK_ADMINISTRATORS = ['msyyc', 'RAY-316', 'BigCat20196']
+_PYTHON_SDK_ASSIGNEES = ['RAY-316', 'BigCat20196']
+_ASSIGNER_DICT = {'RAY-316': os.getenv('ZED_TOKEN'), 'BigCat20196': os.getenv('JF_TOKEN')}
 logging.basicConfig(level=logging.INFO,
                     format='[auto-reply  log] - %(funcName)s[line:%(lineno)d] - %(levelname)s: %(message)s')
 
@@ -128,7 +130,7 @@ def _latest_comment_time(comments, delay_from_create_date):
     return delay_from_create_date if not q else int((time.time() - q[-1][0]) / 3600 / 24)
 
 
-def auto_reply(item, request_repo, rest_repo, sdk_repo, duplicated_issue, python_piplines):
+def auto_reply(item, request_repo, rest_repo, sdk_repo, duplicated_issue, python_piplines, assigner_repoes):
     logging.info("new issue number: {}".format(item.issue_object.number))
 
     if 'auto-link' not in item.labels:
@@ -156,8 +158,9 @@ def auto_reply(item, request_repo, rest_repo, sdk_repo, duplicated_issue, python
     try:
         logging.info(python_piplines)
         pipeline_url = get_pipeline_url(python_piplines, output_folder)
+        assigner_repo = assigner_repoes[item.assignee]
         rg.begin_reply_generate(item=item, rest_repo=rest_repo, readme_link=readme_link,
-                                sdk_repo=sdk_repo, pipeline_url=pipeline_url)
+                                sdk_repo=sdk_repo, pipeline_url=pipeline_url, assigner_repo=assigner_repo)
         if 'Configured' in item.labels:
             item.issue_object.remove_from_labels('Configured')
     except Exception as e:
@@ -170,8 +173,11 @@ def auto_reply(item, request_repo, rest_repo, sdk_repo, duplicated_issue, python
 def main():
     # get latest issue status
     g = Github(os.getenv('TOKEN'))  # please fill user_token
+    assigner_repoes = {}
+    for k, v in _ASSIGNER_DICT.items():
+        assigner_repoes[k] = Github(v).get_repo('Azure/sdk-release-request')
     request_repo = g.get_repo('Azure/sdk-release-request')
-    rest_repo = g.get_repo('Azure/azure-rest-api-specs')   
+    rest_repo = g.get_repo('Azure/azure-rest-api-specs')
     sdk_repo = g.get_repo('Azure/azure-sdk-for-python')
     label1 = request_repo.get_label('ManagementPlane')
     open_issues = request_repo.get_issues(state='open', labels=[label1])
@@ -226,13 +232,13 @@ def main():
             item.bot_advice = 'new issue and better to confirm quickly.'
             if 'assigned' not in item.labels:
                 time.sleep(0.1)
-                assign_count = int(str(time.time())[-1]) % 2
-                if assign_count == 1:
-                    item.issue_object.remove_from_assignees(*['RAY-316'])
-                    item.issue_object.add_to_assignees(*['BigCat20196'])
+                assign_count = int(str(time.time())[-1]) % len(_PYTHON_SDK_ASSIGNEES)
+                item.issue_object.remove_from_assignees(item.assignee)
+                item.issue_object.add_to_assignees(_PYTHON_SDK_ASSIGNEES[assign_count])
+                item.assignee=item.issue_object.assignee.login
                 item.issue_object.add_to_labels('assigned')
             try:
-                auto_reply(item, request_repo, rest_repo, sdk_repo, duplicated_issue, python_piplines)
+                auto_reply(item, request_repo, rest_repo, sdk_repo, duplicated_issue, python_piplines, assigner_repoes)
             except Exception as e:
                 continue
         elif not item.author_latest_comment in _PYTHON_SDK_ADMINISTRATORS:

scripts/release_issue_status/release_issue_status.yml

@@ -39,6 +39,8 @@ jobs:
         export HEADERS=$(PIPELINE_HEADERS)
         export URL=$(PIPELINE_URL)
         export PIPELINE_TOKEN=$(PIPELINE-TOKEN)
+        export JF_TOKEN=$(Jiefeng-GitToken)
+        export ZED_TOKEN=$(Zed-GitToken)
         export COOKIE=$(USR_TOKEN)
 
         # create virtual env

scripts/release_issue_status/reply_generator.py

@@ -52,8 +52,10 @@ def get_latest_pr_from_readme(rest_repo, link_dict):
     return latest_pr_number_int[-1]
 
 
-def reply_owner(reply_content):
-    issue_object_rg.create_comment(reply_content)
+def reply_owner(assigner_issue, reply_content):
+    assigner_issue.create_comment(reply_content)
+    user_tips = 'Tips: If you have special needs for release date or other things, please let us know. Otherwise we will release it ASAP after your check.'
+    assigner_issue.create_comment(user_tips)
 
 
 
@@ -74,7 +76,7 @@ def get_reply_and_sdk_number_from_readme(rest_repo, link_dict):
     return info_model, sdk_link_number
 
 
-def begin_reply_generate(item, rest_repo, readme_link, sdk_repo, pipeline_url):
+def begin_reply_generate(item, rest_repo, readme_link, sdk_repo, pipeline_url, assigner_repo):
     global issue_object_rg
     issue_object_rg = item.issue_object
     link_dict = get_links(readme_link)
@@ -91,7 +93,8 @@ def begin_reply_generate(item, rest_repo, readme_link, sdk_repo, pipeline_url):
             logging.info(f'{issue_object_rg.number} run pipeline successfully')
         else:
             logging.info(f'{issue_object_rg.number} run pipeline fail')
-        reply_owner(reply_content)
+        assigner_issue = assigner_repo.get_issue(number=issue_object_rg.number)
+        reply_owner(assigner_issue, reply_content)
         issue_object_rg.add_to_labels('auto-ask-check')
     else:
         logging.info('issue {} need config readme'.format(issue_object_rg.number))