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.7.tar.gz (5.3 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.7-py3-none-any.whl (9.0 kB view details)

Uploaded Python 3

File details

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

File metadata

  • Download URL: speaksynk_flow_processor-1.2.7.tar.gz
  • Upload date:
  • Size: 5.3 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.7.tar.gz
Algorithm Hash digest
SHA256 6f58fae8b28d344b1cd85eefa56e728a543edde9fabdb711c1521372e10827dc
MD5 2f9b31fbf294981f85ee4540c43b3443
BLAKE2b-256 dcf2a9ff95899a03f20791757ac665ca9db8f0422106bb21ae99f8ca35fa2fdf

See more details on using hashes here.

File details

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

File metadata

File hashes

Hashes for speaksynk_flow_processor-1.2.7-py3-none-any.whl
Algorithm Hash digest
SHA256 9d8ec4e7d509c3abbce4283c4183dfe9aa5f765e980f6d0c46250590cbc54bbb
MD5 4c2c112ae3954ec5347569899c956b56
BLAKE2b-256 775de969c496bcb28a3ca23aba4dddd75b8b74d86e43a39613a1ea07f4addba3

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