@@ -75,6 +75,12 @@ async def _perform_commands_gitlab(commands_conf: str, agent: PRAgent, api_url:
75
75
get_logger ().error (f"Failed to perform command { command } : { e } " )
76
76
77
77
78
+ def should_skip_mr (draft : bool , mr_url : str ):
79
+ skip_draft_mr = get_settings ().get ("GITLAB.SKIP_DRAFT_MR" , False )
80
+ if draft and skip_draft_mr :
81
+ get_logger ().info (f"Skipping draft MR: { mr_url } " )
82
+ return True
83
+ return False
78
84
79
85
@router .post ("/webhook" )
80
86
async def gitlab_webhook (background_tasks : BackgroundTasks , request : Request ):
@@ -130,8 +136,7 @@ async def inner(data: dict):
130
136
url = data ['object_attributes' ].get ('url' )
131
137
draft = data ['object_attributes' ].get ('draft' )
132
138
133
- if draft and skip_draft_mr :
134
- get_logger ().info (f"Skipping draft MR: { url } " )
139
+ if should_skip_mr (draft , url ):
135
140
return JSONResponse (status_code = status .HTTP_200_OK , content = jsonable_encoder ({"message" : "success" }))
136
141
137
142
get_logger ().info (f"New merge request: { url } " )
@@ -143,8 +148,7 @@ async def inner(data: dict):
143
148
draft = mr .get ('draft' )
144
149
145
150
get_logger ().info (f"A comment has been added to a merge request: { url } " )
146
- if draft and skip_draft_mr :
147
- get_logger ().info (f"Skipping draft MR: { url } " )
151
+ if should_skip_mr (draft , url ):
148
152
return JSONResponse (status_code = status .HTTP_200_OK , content = jsonable_encoder ({"message" : "success" }))
149
153
150
154
body = data .get ('object_attributes' , {}).get ('note' )
0 commit comments