TRAVIS_OS_NAME=linux TOXENV=3.7 IDENT=3.7.5 TRAVIS_PYTHON_VERSION=3.7.5 <<<<<< ENV .coveragerc .editorconfig .github/CODE_OF_CONDUCT.md .github/ISSUE_TEMPLATE.md .github/PULL_REQUEST_TEMPLATE.md .gitignore .pre-commit-config.yaml .pyup.yml .travis.yml AUTHORS.rst CODE_OF_CONDUCT.rst CONTRIBUTING.rst Changelog.rst LICENSE MANIFEST.in Makefile README.rst TODO.rst artwork/LICENSE artwork/banner-alt1.png artwork/banner-alt2.png artwork/favicon.ico artwork/logo.png docs/Makefile docs/_ext/faustdocs.py docs/_ext/typehints.py docs/_static/.keep docs/_templates/.keep docs/authors.rst docs/changelog.rst docs/conf.py docs/contributing.rst docs/copyright.rst docs/developerguide/index.rst docs/developerguide/overview.rst docs/developerguide/partition_assignor.rst docs/faq.rst docs/glossary.rst docs/history/changelog-0.9.rst docs/history/changelog-1.0.rst docs/history/changelog-1.1.rst docs/history/changelog-1.10.rst docs/history/changelog-1.2.rst docs/history/changelog-1.3.rst docs/history/changelog-1.4.rst docs/history/changelog-1.5.rst docs/history/changelog-1.6.rst docs/history/changelog-1.7.rst docs/history/changelog-1.8.rst docs/history/changelog-1.9.rst docs/history/index.rst docs/images/banner-alt1.png docs/images/banner-alt2.png docs/images/favicon.ico docs/images/logo.png docs/includes/blurb.txt docs/includes/code-of-conduct.txt docs/includes/faq.txt docs/includes/installation.txt docs/includes/intro.txt docs/includes/introduction.txt docs/includes/kafka.txt docs/includes/resources.txt docs/includes/settingref.txt docs/includes/tags.txt docs/index.rst docs/introduction.rst docs/make.bat docs/playbooks/cheatsheet.rst docs/playbooks/index.rst docs/playbooks/leaderelection.rst docs/playbooks/pageviews.rst docs/playbooks/quickstart.rst docs/playbooks/vscelery.rst docs/playbooks/vskafka.rst docs/reference/faust.agents.actor.rst docs/reference/faust.agents.agent.rst docs/reference/faust.agents.manager.rst docs/reference/faust.agents.models.rst docs/reference/faust.agents.replies.rst docs/reference/faust.agents.rst docs/reference/faust.app.base.rst docs/reference/faust.app.router.rst docs/reference/faust.app.rst docs/reference/faust.assignor.client_assignment.rst docs/reference/faust.assignor.cluster_assignment.rst docs/reference/faust.assignor.copartitioned_assignor.rst docs/reference/faust.assignor.leader_assignor.rst docs/reference/faust.assignor.partition_assignor.rst docs/reference/faust.auth.rst docs/reference/faust.channels.rst docs/reference/faust.cli.agents.rst docs/reference/faust.cli.base.rst docs/reference/faust.cli.clean_versions.rst docs/reference/faust.cli.completion.rst docs/reference/faust.cli.faust.rst docs/reference/faust.cli.livecheck.rst docs/reference/faust.cli.model.rst docs/reference/faust.cli.models.rst docs/reference/faust.cli.params.rst docs/reference/faust.cli.reset.rst docs/reference/faust.cli.send.rst docs/reference/faust.cli.tables.rst docs/reference/faust.cli.worker.rst docs/reference/faust.contrib.rst docs/reference/faust.contrib.sentry.rst docs/reference/faust.events.rst docs/reference/faust.exceptions.rst docs/reference/faust.fixups.base.rst docs/reference/faust.fixups.django.rst docs/reference/faust.fixups.rst docs/reference/faust.joins.rst docs/reference/faust.livecheck.app.rst docs/reference/faust.livecheck.case.rst docs/reference/faust.livecheck.exceptions.rst docs/reference/faust.livecheck.locals.rst docs/reference/faust.livecheck.models.rst docs/reference/faust.livecheck.patches.aiohttp.rst docs/reference/faust.livecheck.patches.rst docs/reference/faust.livecheck.rst docs/reference/faust.livecheck.runners.rst docs/reference/faust.livecheck.signals.rst docs/reference/faust.models.base.rst docs/reference/faust.models.fields.rst docs/reference/faust.models.record.rst docs/reference/faust.models.tags.rst docs/reference/faust.models.typing.rst docs/reference/faust.rst docs/reference/faust.sensors.base.rst docs/reference/faust.sensors.datadog.rst docs/reference/faust.sensors.monitor.rst docs/reference/faust.sensors.prometheus.rst docs/reference/faust.sensors.rst docs/reference/faust.sensors.statsd.rst docs/reference/faust.serializers.codecs.rst docs/reference/faust.serializers.registry.rst docs/reference/faust.serializers.schemas.rst docs/reference/faust.stores.base.rst docs/reference/faust.stores.memory.rst docs/reference/faust.stores.rocksdb.rst docs/reference/faust.stores.rst docs/reference/faust.streams.rst docs/reference/faust.tables.base.rst docs/reference/faust.tables.globaltable.rst docs/reference/faust.tables.manager.rst docs/reference/faust.tables.objects.rst docs/reference/faust.tables.recovery.rst docs/reference/faust.tables.rst docs/reference/faust.tables.sets.rst docs/reference/faust.tables.table.rst docs/reference/faust.tables.wrappers.rst docs/reference/faust.topics.rst docs/reference/faust.transport.base.rst docs/reference/faust.transport.conductor.rst docs/reference/faust.transport.consumer.rst docs/reference/faust.transport.drivers.aiokafka.rst docs/reference/faust.transport.drivers.rst docs/reference/faust.transport.producer.rst docs/reference/faust.transport.rst docs/reference/faust.transport.utils.rst docs/reference/faust.types.agents.rst docs/reference/faust.types.app.rst docs/reference/faust.types.assignor.rst docs/reference/faust.types.auth.rst docs/reference/faust.types.channels.rst docs/reference/faust.types.codecs.rst docs/reference/faust.types.core.rst docs/reference/faust.types.enums.rst docs/reference/faust.types.events.rst docs/reference/faust.types.fixups.rst docs/reference/faust.types.joins.rst docs/reference/faust.types.models.rst docs/reference/faust.types.router.rst docs/reference/faust.types.sensors.rst docs/reference/faust.types.serializers.rst docs/reference/faust.types.settings.base.rst docs/reference/faust.types.settings.params.rst docs/reference/faust.types.settings.rst docs/reference/faust.types.settings.sections.rst docs/reference/faust.types.settings.settings.rst docs/reference/faust.types.stores.rst docs/reference/faust.types.streams.rst docs/reference/faust.types.tables.rst docs/reference/faust.types.topics.rst docs/reference/faust.types.transports.rst docs/reference/faust.types.tuples.rst docs/reference/faust.types.web.rst docs/reference/faust.types.windows.rst docs/reference/faust.utils.codegen.rst docs/reference/faust.utils.cron.rst docs/reference/faust.utils.functional.rst docs/reference/faust.utils.iso8601.rst docs/reference/faust.utils.json.rst docs/reference/faust.utils.platforms.rst docs/reference/faust.utils.terminal.rst docs/reference/faust.utils.terminal.spinners.rst docs/reference/faust.utils.terminal.tables.rst docs/reference/faust.utils.tracing.rst docs/reference/faust.utils.urls.rst docs/reference/faust.utils.venusian.rst docs/reference/faust.web.apps.graph.rst docs/reference/faust.web.apps.router.rst docs/reference/faust.web.apps.stats.rst docs/reference/faust.web.base.rst docs/reference/faust.web.blueprints.rst docs/reference/faust.web.cache.backends.base.rst docs/reference/faust.web.cache.backends.memory.rst docs/reference/faust.web.cache.backends.redis.rst docs/reference/faust.web.cache.backends.rst docs/reference/faust.web.cache.cache.rst docs/reference/faust.web.cache.exceptions.rst docs/reference/faust.web.cache.rst docs/reference/faust.web.drivers.aiohttp.rst docs/reference/faust.web.drivers.rst docs/reference/faust.web.exceptions.rst docs/reference/faust.web.views.rst docs/reference/faust.windows.rst docs/reference/faust.worker.rst docs/reference/index.rst docs/spelling_wordlist.txt docs/templates/readme.txt docs/userguide/agents.rst docs/userguide/application.rst docs/userguide/channels.rst docs/userguide/cli.rst docs/userguide/debugging.rst docs/userguide/index.rst docs/userguide/installation.rst docs/userguide/kafka.rst docs/userguide/livecheck.rst docs/userguide/models.rst docs/userguide/sensors.rst docs/userguide/settings.rst docs/userguide/streams.rst docs/userguide/tables.rst docs/userguide/tasks.rst docs/userguide/testing.rst docs/userguide/workers.rst environment.yml examples/__init__.py examples/advanced/isolated_partitions_crashing.py examples/advanced/rpc.py examples/advanced/service.py examples/concurrency.py examples/crontab/tz_aware.py examples/crontab/tz_unaware.py examples/django/README.rst examples/django/accounts/__init__.py examples/django/accounts/agents.py examples/django/accounts/apps.py examples/django/accounts/migrations/0001_initial.py examples/django/accounts/migrations/__init__.py examples/django/accounts/models.py examples/django/faustapp/__init__.py examples/django/faustapp/app.py examples/django/faustapp/apps.py examples/django/faustapp/migrations/__init__.py examples/django/manage.py examples/django/proj/__init__.py examples/django/proj/__main__.py examples/django/proj/settings.py examples/django/proj/urls.py examples/django/proj/wsgi.py examples/django/requirements/default.txt examples/django/requirements/test.txt examples/django/setup.py examples/hello_world.py examples/kubernetes/README.md examples/kubernetes/consumer/Dockerfile examples/kubernetes/consumer/README.md examples/kubernetes/consumer/consumer.py examples/kubernetes/consumer/consumer.yml examples/kubernetes/consumer/requirements.txt examples/kubernetes/producer/Dockerfile examples/kubernetes/producer/README.md examples/kubernetes/producer/producer.py examples/kubernetes/producer/producer.yml examples/kubernetes/producer/requirements.txt examples/leader.py examples/livecheck.py examples/tableofset.py examples/tabletest.py examples/task_queue.py examples/windowed_aggregation.py examples/windowing/hopping.py examples/windowing/tumbling.py examples/withdrawals.py examples/word_count.py extra/bandit/baseline.json extra/bandit/config.yaml extra/macOS/com.fauststream.worker.plist extra/release/sphinx2rst_config.py extra/supervisord/faust.conf extra/supervisord/supervisord.conf extra/systemd/faust.conf extra/systemd/faust.service extra/systemd/faust.tmpfiles extra/tools/benchmark.py extra/tools/render_configuration_reference.py extra/tools/verify_ascending.py extra/tools/verify_doc_defaults.py extra/tools/verify_tabletest.sh extra/tools/verify_tabletest_changelog.py faust/__init__.py faust/__main__.py faust/_cython/__init__.py faust/_cython/streams.pyx faust/_cython/windows.pyx faust/agents/__init__.py faust/agents/actor.py faust/agents/agent.py faust/agents/manager.py faust/agents/models.py faust/agents/replies.py faust/app/__init__.py faust/app/_attached.py faust/app/base.py faust/app/router.py faust/assignor/__init__.py faust/assignor/client_assignment.py faust/assignor/cluster_assignment.py faust/assignor/copartitioned_assignor.py faust/assignor/leader_assignor.py faust/assignor/partition_assignor.py faust/auth.py faust/channels.py faust/cli/__init__.py faust/cli/agents.py faust/cli/base.py faust/cli/clean_versions.py faust/cli/completion.py faust/cli/faust.py faust/cli/livecheck.py faust/cli/model.py faust/cli/models.py faust/cli/params.py faust/cli/reset.py faust/cli/send.py faust/cli/tables.py faust/cli/worker.py faust/contrib/__init__.py faust/contrib/sentry.py faust/events.py faust/exceptions.py faust/fixups/__init__.py faust/fixups/base.py faust/fixups/django.py faust/joins.py faust/livecheck/__init__.py faust/livecheck/app.py faust/livecheck/case.py faust/livecheck/exceptions.py faust/livecheck/locals.py faust/livecheck/models.py faust/livecheck/patches/__init__.py faust/livecheck/patches/aiohttp.py faust/livecheck/runners.py faust/livecheck/signals.py faust/models/__init__.py faust/models/base.py faust/models/fields.py faust/models/record.py faust/models/tags.py faust/models/typing.py faust/py.typed faust/sensors/__init__.py faust/sensors/base.py faust/sensors/datadog.py faust/sensors/monitor.py faust/sensors/prometheus.py faust/sensors/statsd.py faust/serializers/__init__.py faust/serializers/codecs.py faust/serializers/registry.py faust/serializers/schemas.py faust/stores/__init__.py faust/stores/base.py faust/stores/memory.py faust/stores/rocksdb.py faust/streams.py faust/tables/__init__.py faust/tables/base.py faust/tables/globaltable.py faust/tables/manager.py faust/tables/objects.py faust/tables/recovery.py faust/tables/sets.py faust/tables/table.py faust/tables/wrappers.py faust/topics.py faust/transport/__init__.py faust/transport/_cython/__init__.py faust/transport/_cython/conductor.pyx faust/transport/base.py faust/transport/conductor.py faust/transport/consumer.py faust/transport/drivers/__init__.py faust/transport/drivers/aiokafka.py faust/transport/drivers/confluent.py faust/transport/producer.py faust/transport/utils.py faust/types/__init__.py faust/types/_env.py faust/types/agents.py faust/types/app.py faust/types/assignor.py faust/types/auth.py faust/types/channels.py faust/types/codecs.py faust/types/core.py faust/types/enums.py faust/types/events.py faust/types/fixups.py faust/types/joins.py faust/types/models.py faust/types/router.py faust/types/sensors.py faust/types/serializers.py faust/types/settings/__init__.py faust/types/settings/base.py faust/types/settings/params.py faust/types/settings/sections.py faust/types/settings/settings.py faust/types/stores.py faust/types/streams.py faust/types/tables.py faust/types/topics.py faust/types/transports.py faust/types/tuples.py faust/types/web.py faust/types/windows.py faust/utils/__init__.py faust/utils/_iso8601_python.py faust/utils/codegen.py faust/utils/cron.py faust/utils/functional.py faust/utils/iso8601.py faust/utils/json.py faust/utils/kafka/__init__.py faust/utils/kafka/protocol/__init__.py faust/utils/kafka/protocol/admin.py faust/utils/kafka/protocol/api.py faust/utils/platforms.py faust/utils/terminal/__init__.py faust/utils/terminal/spinners.py faust/utils/terminal/tables.py faust/utils/tracing.py faust/utils/urls.py faust/utils/venusian.py faust/web/__init__.py faust/web/apps/__init__.py faust/web/apps/graph.py faust/web/apps/production_index.py faust/web/apps/router.py faust/web/apps/stats.py faust/web/apps/tables.py faust/web/base.py faust/web/blueprints.py faust/web/cache/__init__.py faust/web/cache/backends/__init__.py faust/web/cache/backends/base.py faust/web/cache/backends/memory.py faust/web/cache/backends/redis.py faust/web/cache/cache.py faust/web/cache/exceptions.py faust/web/drivers/__init__.py faust/web/drivers/aiohttp.py faust/web/exceptions.py faust/web/views.py faust/windows.py faust/worker.py readthedocs.yml requirements/README.rst requirements/ci.txt requirements/default.txt requirements/dist.txt requirements/docs-plugins.txt requirements/docs.txt requirements/extras/aiodns.txt requirements/extras/aiomonitor.txt requirements/extras/cchardet.txt requirements/extras/ciso8601.txt requirements/extras/ckafka.txt requirements/extras/cython.txt requirements/extras/datadog.txt requirements/extras/debug.txt requirements/extras/eventlet.txt requirements/extras/fast.txt requirements/extras/orjson.txt requirements/extras/prometheus.txt requirements/extras/redis.txt requirements/extras/rocksdb.txt requirements/extras/sentry.txt requirements/extras/setproctitle.txt requirements/extras/statsd.txt requirements/extras/uvloop.txt requirements/extras/yaml.txt requirements/flakes.txt requirements/spell.txt requirements/test.txt requirements/typecheck.txt setup.cfg setup.py t/__init__.py t/bench/__init__.py t/bench/base.py t/bench/baseline.py t/bench/forward.py t/conftest.py t/consistency/.gitignore t/consistency/__init__.py t/consistency/consistency_checker.py t/consistency/test_consistency.py t/docs/__init__.py t/docs/testing/__init__.py t/docs/testing/test_figB_agent_to_agent.py t/docs/testing/test_figC_windowed_table.py t/functional/__init__.py t/functional/agents/__init__.py t/functional/agents/helpers.py t/functional/agents/test_concurrency.py t/functional/agents/test_current_agent.py t/functional/agents/test_isolated_partitions.py t/functional/conftest.py t/functional/helpers.py t/functional/models/__init__.py t/functional/models/test_typing.py t/functional/sensors/__init__.py t/functional/sensors/test_statsd.py t/functional/serializers/__init__.py t/functional/serializers/test_registry.py t/functional/test_aiokafka.py t/functional/test_app.py t/functional/test_channels.py t/functional/test_faust.py t/functional/test_models.py t/functional/test_streams.py t/functional/web/__init__.py t/functional/web/conftest.py t/functional/web/test_cache.py t/functional/web/test_tables.py t/functional/web/test_views.py t/helpers.py t/integration/app.py t/integration/cli/__init__.py t/integration/cli/test_agents.py t/integration/cli/test_base.py t/integration/cli/test_model.py t/integration/cli/test_models.py t/integration/conftest.py t/meticulous/assignor/__init__.py t/meticulous/assignor/test_copartitioned_assignor.py t/old/__init__.py t/old/app.py t/old/test_simple.py t/regression/__init__.py t/regression/i323/__init__.py t/regression/i323/conftest.py t/regression/i323/proj323/__init__.py t/regression/i323/proj323/faust.py t/regression/i323/proj323/foo/__init__.py t/regression/i323/proj323/foo/bar/__init__.py t/regression/i323/proj323/foo/bar/baz/__init__.py t/regression/i323/proj323/foo/bar/baz/commands.py t/regression/i323/test_autodiscover.py t/regression/i324/__init__.py t/regression/i324/conftest.py t/regression/i324/proj324/__init__.py t/regression/i324/proj324/__main__.py t/regression/i324/proj324/faust.py t/regression/i324/proj324/foo/__init__.py t/regression/i324/proj324/foo/bar/__init__.py t/regression/i324/proj324/foo/bar/baz/__init__.py t/regression/i324/proj324/foo/bar/baz/commands.py t/regression/i324/proj324/foo/test_x.py t/regression/i324/test_autodiscover.py t/stress/__init__.py t/stress/app.py t/stress/config.py t/stress/killer.py t/stress/models.py t/stress/producer.py t/stress/reports/__init__.py t/stress/reports/app.py t/stress/reports/checks.py t/stress/reports/collector.py t/stress/reports/logging.py t/stress/reports/models.py t/stress/reports/states.py t/stress/reports/templates/dashboard.html t/stress/reports/web.py t/stress/requirements.txt t/stress/tests/__init__.py t/stress/tests/forwarder/__init__.py t/stress/tests/forwarder/app.py t/stress/tests/forwarder/requirements.txt t/stress/tests/simple/__init__.py t/stress/tests/simple/app.py t/stress/tests/simple/requirements.txt t/stress/tests/tables/__init__.py t/stress/tests/tables/app.py t/stress/tests/tables/requirements.txt t/unit/__init__.py t/unit/agents/__init__.py t/unit/agents/test_actor.py t/unit/agents/test_agent.py t/unit/agents/test_manager.py t/unit/agents/test_replies.py t/unit/app/test_base.py t/unit/app/test_router.py t/unit/app/test_service.py t/unit/cli/__init__.py t/unit/cli/conftest.py t/unit/cli/test_base.py t/unit/cli/test_clean_versions.py t/unit/cli/test_completion.py t/unit/cli/test_env.py t/unit/cli/test_params.py t/unit/conftest.py t/unit/fixups/__init__.py t/unit/fixups/test_base.py t/unit/fixups/test_django.py t/unit/livecheck/__init__.py t/unit/livecheck/conftest.py t/unit/livecheck/patches/test_aiohttp.py t/unit/livecheck/test_app.py t/unit/livecheck/test_case.py t/unit/livecheck/test_locals.py t/unit/livecheck/test_models.py t/unit/livecheck/test_runners.py t/unit/livecheck/test_signals.py t/unit/models/__init__.py t/unit/models/test_fields.py t/unit/models/test_tags.py t/unit/sensors/__init__.py t/unit/sensors/test_base.py t/unit/sensors/test_datadog.py t/unit/sensors/test_monitor.py t/unit/sensors/test_prometheus.py t/unit/sensors/test_statsd.py t/unit/serializers/__init__.py t/unit/serializers/test_codecs.py t/unit/stores/__init__.py t/unit/stores/test_base.py t/unit/stores/test_memory.py t/unit/stores/test_rocksdb.py t/unit/tables/__init__.py t/unit/tables/test_base.py t/unit/tables/test_manager.py t/unit/tables/test_objects.py t/unit/tables/test_recovery.py t/unit/tables/test_sets.py t/unit/tables/test_table.py t/unit/tables/test_wrappers.py t/unit/test_auth.py t/unit/test_events.py t/unit/test_faust.py t/unit/test_joins.py t/unit/test_streams.py t/unit/test_topics.py t/unit/test_worker.py t/unit/transport/drivers/__init__.py t/unit/transport/drivers/test_aiokafka.py t/unit/transport/test_conductor.py t/unit/transport/test_consumer.py t/unit/transport/test_producer.py t/unit/transport/test_utils.py t/unit/utils/__init__.py t/unit/utils/terminal/__init__.py t/unit/utils/terminal/test_spinners.py t/unit/utils/terminal/test_tables.py t/unit/utils/test_codegen.py t/unit/utils/test_cron.py t/unit/utils/test_functional.py t/unit/utils/test_iso8601.py t/unit/utils/test_json.py t/unit/utils/test_urls.py t/unit/utils/test_utils.py t/unit/utils/test_venusian.py t/unit/web/__init__.py t/unit/web/drivers/__init__.py t/unit/web/drivers/test_aiohttp.py t/unit/web/test_base.py t/unit/web/test_blueprints.py t/unit/web/test_exceptions.py t/unit/web/test_views.py t/unit/windows/test_hopping_window.py t/unit/windows/test_sliding_window.py t/unit/windows/test_tumbling_window.py tox.ini <<<<<< network # path=/home/travis/build/robinhood/faust/coverage.xml /home/travis/build/robinhood/faust <<<<<< EOF