Skip to main content

No project description provided

Project description

SpeakSynk Flow Processor

Parent class to create steps, ideally this will save us some common functions of the steps.

Implementation

from speaksynk_flow_processor.AWSSpeakSynkFlowProcesor import AWSSpeakSynkFlowProcesor


class Implementation(AWSSpeakSynkFlowProcesor):
    def __init__(self):
        super().__init__()
        self.filekey = "break_time/%s" % self._identifier
        self.local_file = "out.txt"


    def run(self):
        super().run(self)
        self.download('xxxxx')
        '''
            Do your logic here
        '''
        self.upload('xxxx', 'xxxxx')

    def close(self):
        super().close(self)
        '''
            Do your close logic here
        '''


Ideally this save us some time in creating more steps and only taking care of the run method

CLI

By default we have designed a CLI to run the steps, in order to run the steps you can run poetry run speaksynk-steps run this method will automalically instatiate the method and run the proper methods.

Install

  • pip install poetry
  • poetry install

Test

  • poetry run pytest

Use

  • poetry run speaksynk-steps run

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

speaksynk_flow_processor-1.2.3.tar.gz (5.2 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

speaksynk_flow_processor-1.2.3-py3-none-any.whl (8.9 kB view details)

Uploaded Python 3

File details

Details for the file speaksynk_flow_processor-1.2.3.tar.gz.

File metadata

  • Download URL: speaksynk_flow_processor-1.2.3.tar.gz
  • Upload date:
  • Size: 5.2 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/1.7.1 CPython/3.11.7 Linux/6.2.0-1019-azure

File hashes

Hashes for speaksynk_flow_processor-1.2.3.tar.gz
Algorithm Hash digest
SHA256 111549979cda4355ff3689b05a684dc07da1a041b24125a5091418dc0b2cab0c
MD5 522a39b83bd24c6fb4a9bd841c933883
BLAKE2b-256 3fa9013008f2360656a264072c7363d4432f5e8094e56cc55a7c4ac82acc8f7d

See more details on using hashes here.

File details

Details for the file speaksynk_flow_processor-1.2.3-py3-none-any.whl.

File metadata

File hashes

Hashes for speaksynk_flow_processor-1.2.3-py3-none-any.whl
Algorithm Hash digest
SHA256 d84fb16853d1f0dbbc6a719cdfb1c0ecbdf817e8c2786cfaf0bd26c41d6fdc3f
MD5 6692fbbbdfd52403235b6e96e131cd61
BLAKE2b-256 94fff5e3d2fb87974fb7e60314fca72938ce2203a75d356ba9aa4af9354089f1

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page