Skip to content

Commit 9b47b6c

Browse files
committed
create dummy log stream for step machine
1 parent 15f9fef commit 9b47b6c

File tree

1 file changed

+23
-2
lines changed

1 file changed

+23
-2
lines changed

serverless/aws/features/stepfunctions.py

Lines changed: 23 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
from typing import Optional
22

33
from serverless.aws.resources.logs import LogGroup
4+
from troposphere.logs import LogStream
45
from serverless.service.plugins.step_functions import StepFunctions as StepFunctionsPlugin
56
from serverless.service.types import Identifier, YamlOrderedDict
67

@@ -298,15 +299,35 @@ def to_yaml(cls, dumper, data):
298299
class StateMachine(YamlOrderedDict):
299300
yaml_tag = "!YamlOrderedDict"
300301

301-
def __init__(self, name, description, events=None, type=None, auto_fallback=True, auto_catch=True, service=None):
302+
def __init__(
303+
self,
304+
name,
305+
description,
306+
events=None,
307+
type=None,
308+
auto_fallback=True,
309+
auto_catch=True,
310+
service=None,
311+
):
302312
self.name = name
303313
self.tracingConfig = dict(enabled=True)
304314

305315
if type:
306316
self.type = type
307317

308-
logs = LogGroup(LogGroupName=f"/stepmachine/{Identifier(self.name).spinal}")
318+
log_group_name = f"/stepmachine/{Identifier(self.name).spinal}"
319+
logs = LogGroup(LogGroupName=log_group_name)
309320
service.resources.add(logs)
321+
service.resources.add(
322+
LogStream(
323+
title=Identifier(self.name + "LogStream").resource,
324+
LogGroupName=log_group_name,
325+
LogStreamName="dummy",
326+
DependsOn=[
327+
logs.resource.title
328+
]
329+
)
330+
)
310331

311332
self.loggingConfig = dict(level="ERROR", includeExecutionData=True, destinations=[logs.get_att("Arn")])
312333
self.definition = Definition(description, auto_fallback, auto_catch)

0 commit comments

Comments
 (0)