From dev-return-3454-archive-asf-public=cust-asf.ponee.io@openwhisk.apache.org Tue Mar 26 14:44:16 2019 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id 77F8C180627 for ; Tue, 26 Mar 2019 15:44:15 +0100 (CET) Received: (qmail 7472 invoked by uid 500); 26 Mar 2019 14:44:14 -0000 Mailing-List: contact dev-help@openwhisk.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@openwhisk.apache.org Delivered-To: mailing list dev@openwhisk.apache.org Received: (qmail 7447 invoked by uid 99); 26 Mar 2019 14:44:13 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 26 Mar 2019 14:44:13 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 76DDFC2CBD for ; Tue, 26 Mar 2019 14:44:13 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.662 X-Spam-Level: ** X-Spam-Status: No, score=2.662 tagged_above=-999 required=6.31 tests=[HTML_MESSAGE=2, KHOP_DYNAMIC=1.363, RCVD_IN_DNSWL_LOW=-0.7, SPF_PASS=-0.001] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id 9sqkKNHT8S-D for ; Tue, 26 Mar 2019 14:44:11 +0000 (UTC) Received: from mx0a-001b2d01.pphosted.com (mx0b-001b2d01.pphosted.com [148.163.158.5]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 710D25F175 for ; Tue, 26 Mar 2019 14:44:11 +0000 (UTC) Received: from pps.filterd (m0098419.ppops.net [127.0.0.1]) by mx0b-001b2d01.pphosted.com (8.16.0.27/8.16.0.27) with SMTP id x2QEcSXB019884 for ; Tue, 26 Mar 2019 10:44:11 -0400 Received: from smtp.notes.na.collabserv.com (smtp.notes.na.collabserv.com [192.155.248.73]) by mx0b-001b2d01.pphosted.com with ESMTP id 2rfp13rds3-1 (version=TLSv1.2 cipher=ECDHE-RSA-AES256-GCM-SHA384 bits=256 verify=NOT) for ; Tue, 26 Mar 2019 10:44:09 -0400 Received: from localhost by smtp.notes.na.collabserv.com with smtp.notes.na.collabserv.com ESMTP for from ; Tue, 26 Mar 2019 14:44:02 -0000 Received: from us1a3-smtp07.a3.dal06.isc4sb.com (10.146.103.14) by smtp.notes.na.collabserv.com (10.106.227.90) with smtp.notes.na.collabserv.com ESMTP; Tue, 26 Mar 2019 14:43:24 -0000 Received: from us1a3-mail108.a3.dal06.isc4sb.com ([10.146.45.126]) by us1a3-smtp07.a3.dal06.isc4sb.com with ESMTP id 2019032614432363-622146 ; Tue, 26 Mar 2019 14:43:23 +0000 In-Reply-To: To: dev@openwhisk.apache.org Subject: Re: Pausing actions, waiting for human input etc. From: "David Breitgand" Date: Tue, 26 Mar 2019 16:43:23 +0200 References: X-KeepSent: 218CE650:38A35826-C22583C9:00509239; type=4; name=$KeepSent X-Mailer: IBM Notes Release 9.0.1FP7 August 18, 2016 X-LLNOutbound: False X-Disclaimed: 8363 X-TNEFEvaluated: 1 Content-Type: multipart/alternative; boundary="=_alternative 0050E05EC22583C9_=" x-cbid: 19032614-3107-0000-0000-00000A80C0C3 X-IBM-SpamModules-Scores: BY=0; FL=0; FP=0; FZ=0; HX=0; KW=0; PH=0; SC=0.417846; ST=0; TS=0; UL=0; ISC=; MB=0.118705 X-IBM-SpamModules-Versions: BY=3.00010818; HX=3.00000242; KW=3.00000007; PH=3.00000004; SC=3.00000282; SDB=6.01179963; UDB=6.00617470; IPR=6.00960678; BA=6.00006267; NDR=6.00000001; ZLA=6.00000005; ZF=6.00000009; ZB=6.00000000; ZP=6.00000000; ZH=6.00000000; ZU=6.00000002; MB=3.00026164; XFM=3.00000015; UTC=2019-03-26 14:44:02 X-IBM-AV-DETECTION: SAVI=unsuspicious REMOTE=unsuspicious XFE=unused X-IBM-AV-VERSION: SAVI=2019-03-26 08:26:06 - 6.00009730 x-cbparentid: 19032614-3108-0000-0000-000065B4DC6F Message-Id: MIME-Version: 1.0 X-Proofpoint-Virus-Version: vendor=fsecure engine=2.50.10434:,, definitions=2019-03-26_10:,, signatures=0 X-Proofpoint-Spam-Reason: safe --=_alternative 0050E05EC22583C9_= Content-Transfer-Encoding: quoted-printable Content-Type: text/plain; charset="US-ASCII" Hi Bertrand,=20 AFAIK, this is not currently possible out of the box, but it will be very=20 useful. At IBM Research -- Haifa, we are thinking about similar functionality for=20 long-running serveless pipelenes over a data lake. I think a generalization of this will be a "state machine", where you can=20 suspend on a different events. Maybe something of the kind should be added to Composer? Thoughts? -- david=20 From: Bertrand Delacretaz To: OpenWhisk Dev Date: 26/03/2019 03:25 PM Subject: Pausing actions, waiting for human input etc. Hi, I'm looking at a way to execute long-running compositions of Actions, including waiting for human inputs with long timeouts in the range of several days. The basic pattern is something like wsk.suspend(someEvent) // this line executes only after that someEvent is received AFAIK that's not currently possible out of the box - but I'd be happy to be proven wrong! Is anyone working on something similar, or are there any prototypes around that go in that direction? Two initial ideas that come to mind is taking inspiration from the way the Composer's Parallel combinator saves state [1], or pausing between invocations of Conductor Actions [2]. I haven't looked at the details of how those work so far. -Bertrand [1]=20 https://urldefense.proofpoint.com/v2/url?u=3Dhttps-3A=5F=5Fgithub.com=5Fapa= che=5Fincubator-2Dopenwhisk-2Dcomposer=5Fblob=5Fmaster=5Fdocs=5FCOMBINATORS= .md-23parallel&d=3DDwIBaQ&c=3Djf=5FiaSHvJObTbx-siA1ZOg&r=3DV=5FhxovuZ2mbhs9= xLcmbhQHjweOY8lKOd0dcgx6t1ZDU&m=3DeboWdranasWuCzZLRloF0r1lmgag7QpiorH6-36gx= hQ&s=3DOhSDKXD0Zi3qXftuAX8QauCoy73j3a=5FmRRNP-mXXi5I&e=3D [2]=20 https://urldefense.proofpoint.com/v2/url?u=3Dhttps-3A=5F=5Fgithub.com=5Fapa= che=5Fincubator-2Dopenwhisk=5Fblob=5Fmaster=5Fdocs=5Fconductors.md&d=3DDwIB= aQ&c=3Djf=5FiaSHvJObTbx-siA1ZOg&r=3DV=5FhxovuZ2mbhs9xLcmbhQHjweOY8lKOd0dcgx= 6t1ZDU&m=3DeboWdranasWuCzZLRloF0r1lmgag7QpiorH6-36gxhQ&s=3DFogDwUOWga=5FAHT= =5FE3dRWFuvVpyqEgaJm97zzSyoMIws&e=3D --=_alternative 0050E05EC22583C9_=--