@@ -41,6 +41,14 @@ objects:
41
41
volumes :
42
42
- name : output-volume
43
43
emptyDir : {}
44
+ - name : workdir
45
+ emptyDir : {}
46
+ - name : kafka-secrets
47
+ secret :
48
+ secretName : " kafka"
49
+ items :
50
+ - key : kafka_ca.crt
51
+ path : kafka_ca.crt
44
52
45
53
arguments :
46
54
parameters :
@@ -62,6 +70,11 @@ objects:
62
70
value : " ${AMUN_BUILD_CPU}"
63
71
- name : build-memory
64
72
value : " ${AMUN_BUILD_MEMORY}"
73
+ # Used for sending messages when inspection completes
74
+ - name : send-messages
75
+ value : " ${THOTH_SEND_MESSAGES}"
76
+ - name : force-sync
77
+ value : " ${THOTH_FORCE_SYNC}"
65
78
# Used in artifact repository to store results
66
79
- name : ceph_bucket_prefix
67
80
- name : ceph_bucket_name
@@ -115,12 +128,54 @@ objects:
115
128
continueOn :
116
129
failed : true
117
130
131
+ - name : create-inspection-complete-message
132
+ dependencies : [inspection-run]
133
+ arguments :
134
+ parameters :
135
+ - name : inspection-id
136
+ value : " {{workflow.parameters.inspection-id}}"
137
+ - name : force-sync
138
+ value : " {{workflow.parameters.force-sync}}"
139
+ templateRef :
140
+ name : create-inspection-complete-message
141
+ template : create-inspection-complete-message
142
+ when : " {{workflow.parameters.send-messages}} == 1"
143
+
144
+ - name : send-messages
145
+ dependencies : [create-inspection-complete-message]
146
+ arguments :
147
+ artifacts :
148
+ - name : messagesdocument
149
+ from : " {{tasks.create-inspection-complete-message.outputs.artifacts.messages_to_be_sent_doc}}"
150
+ parameters :
151
+ - name : THOTH_MESSAGING_FROM_FILE
152
+ value : " /mnt/workdir/messages_to_be_sent.json"
153
+ - name : THOTH_DEPLOYMENT_NAME
154
+ value : " {{workflow.parameters.deployment_name}}"
155
+ - name : THOTH_MESSAGING_CREATE_IF_NOT_EXIST
156
+ value : " 0"
157
+ - name : MESSAGES_DOCUMENT_NAME
158
+ value : " messages_to_be_sent.json"
159
+ templateRef :
160
+ name : " send-messages"
161
+ template : " send-messages"
162
+
118
163
parameters :
119
164
- name : AMUN_INSPECTION_ID
120
165
description : Id of inspection that is run.
121
166
displayName : Inspection id
122
167
required : true
123
168
169
+ - name : THOTH_SEND_MESSAGES
170
+ description : indicates whether message should be sent upon inspection completion
171
+ displayName : send messages
172
+ value : " 1" # sends message by default
173
+
174
+ - name : THOTH_FORCE_SYNC
175
+ description : should inspection complete message cause graph sync job to be run with force sync
176
+ displayName : force sync
177
+ value : " 0"
178
+
124
179
- name : AMUN_RUN_CPU
125
180
description : CPU cores requested for inspection run
126
181
displayName : Run CPU
0 commit comments