fixes

Author: michael-zhao459

datadog_lambda/dsm.py

@@ -68,6 +68,7 @@ def _dsm_set_kinesis_context(event):
         if not context_json:
             logger.debug("DataStreams skipped lambda message: %r", record)
             return None
+
         carrier_get = _create_carrier_get(context_json)
         set_consume_checkpoint("kinesis", arn, carrier_get)