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

Uploaded Python 3

File details

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

File metadata

  • Download URL: speaksynk_flow_processor-1.2.6.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.6.tar.gz
Algorithm Hash digest
SHA256 042905230a5b6ce375393abfd9ced897c6d36623f4cd3b0b9de3cb7e7524ac68
MD5 1001650c8aec25f08998ef6b834374d0
BLAKE2b-256 5ef04c4ca9f2f095d12cb09442c1fdeeccca5deceddf8f07b4714c199cbe4fcd

See more details on using hashes here.

File details

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

File metadata

File hashes

Hashes for speaksynk_flow_processor-1.2.6-py3-none-any.whl
Algorithm Hash digest
SHA256 0534b624eb5f62045a20b80083dc3b6d6cdf1ac43fe2004262e55b4073ecaf71
MD5 e0ae1c12602bd779ba75315d78447045
BLAKE2b-256 f8cfcd97f50f8f78d18c391bdf6946c8b1871b7adb82f4a8dbf876b4b14c8711

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