github/plane
0
0
Fork 1
mirror of https://github.com/makeplane/plane synced 2024-06-14 14:31:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: validation in automation task (#2094)

Browse Source
This commit is contained in:
Bavisetti Narayan 2023-09-05 16:53:53 +05:30 committed by GitHub
parent 928ae775f4
commit 90276073cd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 29 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
apiserver/plane/bgtasks/issue_automation_task.py
View File

@ -64,21 +64,22 @@ def archive_old_issues():
issues_to_update.append(issue) issues_to_update.append(issue)
# Bulk Update the issues and log the activity # Bulk Update the issues and log the activity
updated_issues = Issue.objects.bulk_update( if issues_to_update:
issues_to_update, ["archived_at"], batch_size=100 updated_issues = Issue.objects.bulk_update(
) issues_to_update, ["archived_at"], batch_size=100
[
issue_activity.delay(
type="issue.activity.updated",
requested_data=json.dumps({"archived_at": str(issue.archived_at)}),
actor_id=str(project.created_by_id),
issue_id=issue.id,
project_id=project_id,
current_instance=None,
subscriber=False,
) )
for issue in updated_issues [
] issue_activity.delay(
type="issue.activity.updated",
requested_data=json.dumps({"archived_at": str(issue.archived_at)}),
actor_id=str(project.created_by_id),
issue_id=issue.id,
project_id=project_id,
current_instance=None,
subscriber=False,
)
for issue in updated_issues
]
return return
except Exception as e: except Exception as e:
if settings.DEBUG: if settings.DEBUG:
@ -136,19 +137,20 @@ def close_old_issues():
issues_to_update.append(issue) issues_to_update.append(issue)
# Bulk Update the issues and log the activity # Bulk Update the issues and log the activity
updated_issues = Issue.objects.bulk_update(issues_to_update, ["state"], batch_size=100) if issues_to_update:
[ updated_issues = Issue.objects.bulk_update(issues_to_update, ["state"], batch_size=100)
issue_activity.delay( [
type="issue.activity.updated", issue_activity.delay(
requested_data=json.dumps({"closed_to": str(issue.state_id)}), type="issue.activity.updated",
actor_id=str(project.created_by_id), requested_data=json.dumps({"closed_to": str(issue.state_id)}),
issue_id=issue.id, actor_id=str(project.created_by_id),
project_id=project_id, issue_id=issue.id,
current_instance=None, project_id=project_id,
subscriber=False, current_instance=None,
) subscriber=False,
for issue in updated_issues )
] for issue in updated_issues
]
return return
except Exception as e: except Exception as e:
if settings.DEBUG: if settings.DEBUG: