Skip to content

Commit e145a3a

Browse files
committed
fix feed delete when feed action does not exist
1 parent 233ed02 commit e145a3a

2 files changed

Lines changed: 18 additions & 14 deletions

File tree

commands/trigger.go

Lines changed: 15 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -290,18 +290,22 @@ var triggerDeleteCmd = &cobra.Command{
290290

291291
// If the trigger feed does not exist, it's deleted! This error message will look like
292292
// "could not find trigger /NAMESPACE_ID/TRIGGER_NAME in the database"
293-
if !strings.Contains(err.Error(), "could not find trigger") {
294-
errStr := wski18n.T("Unable to delete trigger '{{.name}}': {{.err}}",
295-
map[string]interface{}{"name": qualifiedName.GetEntityName(), "err": err})
296-
297-
if !Flags.common.force {
298-
werr := whisk.MakeWskErrorFromWskError(errors.New(errStr), err, whisk.EXIT_CODE_ERR_GENERAL, whisk.DISPLAY_MSG, whisk.NO_DISPLAY_USAGE)
299-
return werr
300-
} else {
301-
whisk.Debug(whisk.DbgInfo, "trigger delete is forced despite feed deletion failure\n")
302-
}
293+
// OR if the feed action is not present, there's no way to clean up the feed
294+
// "The requested resource does not exist"
295+
if strings.Contains(err.Error(), "could not find trigger") {
296+
whisk.Debug(whisk.DbgWarn, "trigger feed is already deleted for trigger %s\n", qualifiedName.GetEntityName())
297+
} else if strings.Contains(err.Error(), "The requested resource does not exist") {
298+
whisk.Debug(whisk.DbgWarn, "trigger feed action '%s' does not exist\n", fullFeedName)
303299
} else {
304-
whisk.Debug(whisk.DbgWarn, "trigger feed is already deleted for trigger %s\n", qualifiedName.GetEntityName())
300+
errStr := wski18n.T("Unable to delete trigger '{{.name}}': {{.err}}",
301+
map[string]interface{}{"name": qualifiedName.GetEntityName(), "err": err})
302+
303+
if !Flags.common.force {
304+
werr := whisk.MakeWskErrorFromWskError(errors.New(errStr), err, whisk.EXIT_CODE_ERR_GENERAL, whisk.DISPLAY_MSG, whisk.NO_DISPLAY_USAGE)
305+
return werr
306+
} else {
307+
whisk.Debug(whisk.DbgInfo, "trigger delete is forced despite feed deletion failure\n")
308+
}
305309
}
306310
}
307311

tests/src/test/scala/org/apache/openwhisk/core/cli/test/WskCliBasicUsageTests.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1565,11 +1565,11 @@ class WskCliBasicUsageTests extends TestHelpers with WskTestHelpers {
15651565
val triggerName = withTimestamp("feedDeleteTest")
15661566
val feedActionCreateParams = Map("statusCode" -> JsNumber(200))
15671567

1568-
val pwd = new File(".").getAbsolutePath()
1569-
println(s"PWD: '${pwd}'")
1568+
val feedActionPath = new File(".").getAbsolutePath() + "/src/dat/feed-action-fails-delete.js"
1569+
println(s"feedActionPath: '${feedActionPath}'")
15701570

15711571
assetHelper.withCleaner(wsk.action, actionName) { (action, _) =>
1572-
action.create(actionName, Some(TestUtils.getTestActionFilename("feed-action-fails-delete.js")))
1572+
action.create(actionName, Some(feedActionPath))
15731573
}
15741574

15751575
try {

0 commit comments

Comments
 (0)