Yasuke/moto
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Don't 0-default previous started event ID

Browse Source 
Signed-off-by: Laurie O <laurie_opperman@hotmail.com>
This commit is contained in:
Laurie O 2020-02-26 01:06:58 +10:00
parent a89c150627
commit 369285b7ca
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
moto/swf/models/decision_task.py
View File

@ -15,7 +15,7 @@ class DecisionTask(BaseModel):
self.workflow_type = workflow_execution.workflow_type self.workflow_type = workflow_execution.workflow_type
self.task_token = str(uuid.uuid4()) self.task_token = str(uuid.uuid4())
self.scheduled_event_id = scheduled_event_id self.scheduled_event_id = scheduled_event_id
self.previous_started_event_id = 0 self.previous_started_event_id = None
self.started_event_id = None self.started_event_id = None
self.started_timestamp = None self.started_timestamp = None
self.start_to_close_timeout = ( self.start_to_close_timeout = (
@ -40,10 +40,11 @@ class DecisionTask(BaseModel):
hsh = { hsh = {
"events": [evt.to_dict() for evt in events], "events": [evt.to_dict() for evt in events],
"taskToken": self.task_token, "taskToken": self.task_token,
"previousStartedEventId": self.previous_started_event_id,
"workflowExecution": self.workflow_execution.to_short_dict(), "workflowExecution": self.workflow_execution.to_short_dict(),
"workflowType": self.workflow_type.to_short_dict(), "workflowType": self.workflow_type.to_short_dict(),
} }
if self.previous_started_event_id is not None:
hsh["previousStartedEventId"] = self.previous_started_event_id
if self.started_event_id: if self.started_event_id:
hsh["startedEventId"] = self.started_event_id hsh["startedEventId"] = self.started_event_id
return hsh return hsh

2
tests/test_swf/models/test_decision_task.py
View File

@ -24,7 +24,7 @@ def test_decision_task_full_dict_representation():
fd = dt.to_full_dict() fd = dt.to_full_dict()
fd["events"].should.be.a("list") fd["events"].should.be.a("list")
fd["previousStartedEventId"].should.equal(0) fd.should_not.contain("previousStartedEventId")
fd.should_not.contain("startedEventId") fd.should_not.contain("startedEventId")
fd.should.contain("taskToken") fd.should.contain("taskToken")
fd["workflowExecution"].should.equal(wfe.to_short_dict()) fd["workflowExecution"].should.equal(wfe.to_short_dict())