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.5.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.5-py3-none-any.whl (8.9 kB view details)

Uploaded Python 3

File details

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

File metadata

  • Download URL: speaksynk_flow_processor-1.2.5.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-1018-azure

File hashes

Hashes for speaksynk_flow_processor-1.2.5.tar.gz
Algorithm Hash digest
SHA256 e47816995746f68ab3f5d9e2391419591a116b477e5ee6a9bc9784e6f7625a3e
MD5 a7dac27311c7e4ec3b48de5833f28ff4
BLAKE2b-256 289ef477b95b69155e6dee0cd31333d591a9a17de5669ef6e78b6e1728860b6e

See more details on using hashes here.

File details

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

File metadata

File hashes

Hashes for speaksynk_flow_processor-1.2.5-py3-none-any.whl
Algorithm Hash digest
SHA256 a1a6d1eb3b9931770ea34fde3597945772d412d474abe40e687576515f2e192a
MD5 83e941f6449638d4112d3047ba65c071
BLAKE2b-256 293b5253fa32c09c6e3a8e24bd22df5d71cc5763b1c290574b9d8542bc7d2ae5

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