OSError: No files found based on the file pattern /tmp/tmpjwy4ku73*
self = <apache_beam.io.avroio_test.TestFastAvro testMethod=test_avro_schema_to_beam_schema_with_nullable_atomic_fields>

    @pytest.mark.xlang_sql_expansion_service
    @unittest.skipIf(
        TestPipeline().get_pipeline_options().view_as(StandardOptions).runner is
        None,
        "Must be run with a runner that supports staging java artifacts.")
    def test_avro_schema_to_beam_schema_with_nullable_atomic_fields(self):
      records = []
      records.extend(self.RECORDS)
      records.append({
          'name': 'Bruce', 'favorite_number': None, 'favorite_color': None
      })
      with tempfile.TemporaryDirectory() as tmp_dirname_input:
        input_path = os.path.join(tmp_dirname_input, 'tmp_filename.avro')
        parsed_schema = fastavro.parse_schema(json.loads(self.SCHEMA_STRING))
        with open(input_path, 'wb') as tmp_avro_file:
          fastavro.writer(tmp_avro_file, parsed_schema, records)
    
        with tempfile.TemporaryDirectory() as tmp_dirname_output:
    
          with TestPipeline() as p:
            _ = (
                p
                | avroio.ReadFromAvro(input_path, as_rows=True)
                | SqlTransform("SELECT * FROM PCOLLECTION")
                | avroio.WriteToAvro(tmp_dirname_output))
          with TestPipeline() as p:
>           readback = (p | avroio.ReadFromAvro(tmp_dirname_output + "*"))

apache_beam/io/avroio_test.py:199: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/io/avroio.py:164: in __init__
    self._source = _FastAvroSource(
apache_beam/io/filebasedsource.py:127: in __init__
    self._validate()
apache_beam/options/value_provider.py:193: in _f
    return fnc(self, *args, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <apache_beam.io.avroio._FastAvroSource object at 0x7d8df560fe90>

    @check_accessible(['_pattern'])
    def _validate(self):
      """Validate if there are actual files in the specified glob pattern
      """
      pattern = self._pattern.get()
    
      # Limit the responses as we only want to check if something exists
      match_result = FileSystems.match([pattern], limits=[1])[0]
      if len(match_result.metadata_list) <= 0:
>       raise IOError('No files found based on the file pattern %s' % pattern)
E       OSError: No files found based on the file pattern /tmp/tmpjwy4ku73*

apache_beam/io/filebasedsource.py:190: OSError